Update dags_airflow_fede_k8sexecutor.py

interTwin-eu · Feb 6, 2024 · 4e0e6b3 · 4e0e6b3
1 parent 9ad19ab
commit 4e0e6b3
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/dags_airflow_fede_k8sexecutor.py b/dags_airflow_fede_k8sexecutor.py
@@ -238,9 +238,11 @@ def other_namespace_task():
         #############################################################
 
         # use image from worker node as example
-        repo = conf.get("kubernetes_executor", "worker_container_repository")
-        tag = conf.get("kubernetes_executor", "worker_container_tag")
-
+        # repo = conf.get("kubernetes_executor", "worker_container_repository")
+        # tag = conf.get("kubernetes_executor", "worker_container_tag")
+        repo = "leggerf/rucio-intertwin"
+        tag = "0.0.0"
+
         kube_exec_config_image = {
             "pod_override": k8s.V1Pod(
                 spec=k8s.V1PodSpec(