Update dags_airflow_fede_default_queue.py

interTwin-eu · Jan 30, 2024 · 693d322 · 693d322
1 parent 8092291
commit 693d322
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/dags_airflow_fede_default_queue.py b/dags_airflow_fede_default_queue.py
@@ -374,7 +374,8 @@ def private_image_task():
         # Define DAG execution
         #############################################################
         (
-            [private_image_task, annotation_task]  # first execute this
+            private_image_task
+            >> annotation_task  # first execute this
             >> [other_ns_task, sidecar_task]  # then these
             >> label_task  # then this
             >> [image_task, resource_task]  # then the last two