Update dags_airflow_fede_default_queue.py

interTwin-eu · Jan 30, 2024 · 8092291 · 8092291
1 parent 2882767
commit 8092291
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/dags_airflow_fede_default_queue.py b/dags_airflow_fede_default_queue.py
@@ -351,7 +351,7 @@ def task_with_resource_limits():
                         k8s.V1LocalObjectReference(
                             name="dockerhub",
                         ),
-                    ]
+                    ],
                 )
             )
         }
@@ -369,12 +369,12 @@ def private_image_task():
             log.info("Using image " + f"{repo}:{tag}")
 
         private_image_task = private_image_task()
- 
+
         #############################################################
         # Define DAG execution
         #############################################################
         (
-            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