From f80a8a22f8d7d603fc37fb532a700c5b8fe3e6a5 Mon Sep 17 00:00:00 2001
From: leggerf <41438017+leggerf@users.noreply.github.com>
Date: Tue, 6 Feb 2024 16:38:49 +0100
Subject: [PATCH] Update dags_airflow_fede_rucio_k8sexecutor.py

---
 dags_airflow_fede_rucio_k8sexecutor.py | 13 +++++++------
 1 file changed, 7 insertions(+), 6 deletions(-)

diff --git a/dags_airflow_fede_rucio_k8sexecutor.py b/dags_airflow_fede_rucio_k8sexecutor.py
index 9c8b6ba..5d54169 100644
--- a/dags_airflow_fede_rucio_k8sexecutor.py
+++ b/dags_airflow_fede_rucio_k8sexecutor.py
@@ -44,11 +44,12 @@
         # 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")
+        # repo = conf.get("kubernetes_executor", "worker_container_repository")
+        # tag = conf.get("kubernetes_executor", "worker_container_tag")
 
         kube_exec_config_rucio = {
             "pod_override": k8s.V1Pod(
@@ -56,13 +57,13 @@
                     containers=[
                         k8s.V1Container(
                             name="base",  # the image must be named base
-                            image=f"{repo}:{tag}",
+                            # image=f"{repo}:{tag}",
                             # command=["./get-token.sh"],
                             # image_pull_policy="Always",
                         ),
                         k8s.V1Container(
                             name="sidecar",
-                            image="ubuntu",
+                            image=f"{repo}:{tag}",
                             args=['echo "Hello"'],
                             command=["bash", "-cx"],
                         ),