Update dags_airflow_fede_rucio_k8sexecutor.py

interTwin-eu · Feb 6, 2024 · 9ad19ab · 9ad19ab
1 parent 26b03b7
commit 9ad19ab
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/dags_airflow_fede_rucio_k8sexecutor.py b/dags_airflow_fede_rucio_k8sexecutor.py
@@ -44,8 +44,11 @@
         # Define config for pod with data access at CNAF and rucio
         #############################################################
 
-        repo = "leggerf/rucio-intertwin"
-        tag = "0.0.0"
+        # repo = "leggerf/rucio-intertwin"
+        # tag = "0.0.0"
+        # use image from worker node as example
+        repo = conf.get("kubernetes_executor", "worker_container_repository")
+        tag = conf.get("kubernetes_executor", "worker_container_tag")
 
         kube_exec_config_rucio = {
             "pod_override": k8s.V1Pod(