From 9ad19ab34819201c99dacf4c9f485bd639c50a14 Mon Sep 17 00:00:00 2001
From: leggerf <41438017+leggerf@users.noreply.github.com>
Date: Tue, 6 Feb 2024 12:01:53 +0100
Subject: [PATCH] Update dags_airflow_fede_rucio_k8sexecutor.py

---
 dags_airflow_fede_rucio_k8sexecutor.py | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git a/dags_airflow_fede_rucio_k8sexecutor.py b/dags_airflow_fede_rucio_k8sexecutor.py
index efc1733..ed2e260 100644
--- 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(