Dont force tasks in requires that already exist in airflow

Author: bpblanken

v03_pipeline/lib/tasks/update_lookup_table.py

@@ -91,7 +91,7 @@ def requires(self) -> list[luigi.Task]:
                 self.ignore_missing_samples_when_subsetting,
                 self.ignore_missing_samples_when_remapping,
                 self.validate,
-                self.force,
+                False,
             )
             for (
                 callset_path,

v03_pipeline/lib/tasks/update_project_table.py

@@ -73,7 +73,7 @@ def requires(self) -> luigi.Task:
             self.ignore_missing_samples_when_subsetting,
             self.ignore_missing_samples_when_remapping,
             self.validate,
-            self.force,
+            False,
         )
 
     def initialize_table(self) -> hl.Table:

v03_pipeline/lib/tasks/write_family_table.py

@@ -67,7 +67,7 @@ def requires(self) -> luigi.Task:
             self.ignore_missing_samples_when_subsetting,
             self.ignore_missing_samples_when_remapping,
             self.validate,
-            self.force,
+            False,
         )
 
     def create_table(self) -> hl.Table:

v03_pipeline/lib/tasks/write_new_variants_table.py

@@ -130,7 +130,7 @@ def requires(self) -> list[luigi.Task]:
                         self.ignore_missing_samples_when_subsetting,
                         self.ignore_missing_samples_when_remapping,
                         self.validate,
-                        self.force,
+                        False,
                     )
                     for (
                         callset_path,

v03_pipeline/lib/tasks/write_project_family_tables.py

@@ -64,7 +64,7 @@ def run(self):
             self.ignore_missing_samples_when_subsetting,
             self.ignore_missing_samples_when_remapping,
             self.validate,
-            self.force,
+            False,
         )
         callset_mt = hl.read_matrix_table(rmsct_output.path)
         family_samples = hl.eval(callset_mt.globals.family_samples)

v03_pipeline/lib/tasks/write_remapped_and_subsetted_callset.py

@@ -73,7 +73,7 @@ def requires(self) -> list[luigi.Task]:
                 # Only the primary import task itself should be aware of it.
                 None,
                 self.validate,
-                self.force,
+                False,
             ),
             RawFileTask(self.project_pedigree_path),
         ]