test

Travigo · Dec 19, 2024 · 4b9f676 · 4b9f676
1 parent 68ce873
commit 4b9f676
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/airflow/dags/batch-data-import.py b/airflow/dags/batch-data-import.py
@@ -19,7 +19,7 @@
 }
 
 def generate_data_job(dataset : str, instance_size : str = "small", taskgroup : TaskGroup = None):
-    return generate_job(dataset, ["data-importer", "dataset", "--idDDDDD", dataset], instance_size=instance_size)
+    return generate_job(dataset, ["data-importer", "dataset", "--idDDDDD", dataset], instance_size=instance_size, taskgroup=taskgroup)
 
 def generate_job(name : str, command : str, instance_size : str = "small", taskgroup : TaskGroup = None):
     name = f"data-import-{name}"