Dev

loading_pipeline/lib/tasks/write_existing_variants_parquet.py

@@ -14,6 +14,8 @@
 
 @luigi.util.inherits(BaseLoadingRunParams)
 class WriteExistingVariantsParquetTask(luigi.Task):
+    priority = 1
+
     def output(self) -> luigi.Target:
         return GCSorLocalTarget(
             existing_variants_parquet_path(

loading_pipeline/lib/tasks/write_imported_callset.py

@@ -23,6 +23,8 @@
 
 @luigi.util.inherits(BaseLoadingRunParams)
 class WriteImportedCallsetTask(BaseWriteTask):
+    priority = 2
+
     def complete(self) -> luigi.Target:
         if super().complete():
             mt = hl.read_matrix_table(self.output().path)

loading_pipeline/lib/tasks/write_metadata_for_run.py

@@ -23,6 +23,8 @@
 
 @luigi.util.inherits(BaseLoadingRunParams)
 class WriteMetadataForRunTask(luigi.Task):
+    priority = 2
+
     def output(self) -> luigi.Target:
         return GCSorLocalTarget(
             metadata_for_run_path(