From 0cdc639ccd7a977cad3d77c2da009924bc09e517 Mon Sep 17 00:00:00 2001
From: leggerf <41438017+leggerf@users.noreply.github.com>
Date: Thu, 1 Feb 2024 15:11:28 +0100
Subject: [PATCH] Update dags_airflow_fede_rucio_k8soperator.py

---
 dags_airflow_fede_rucio_k8soperator.py | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git a/dags_airflow_fede_rucio_k8soperator.py b/dags_airflow_fede_rucio_k8soperator.py
index 40057d9..dcd8a96 100644
--- a/dags_airflow_fede_rucio_k8soperator.py
+++ b/dags_airflow_fede_rucio_k8soperator.py
@@ -10,9 +10,14 @@
 
 dag = DAG('rucio_operator', default_args=default_args, schedule_interval=None)
 
+repo = "leggerf/rucio-intertwin"
+tag = "0.0.0"
+
 k = KubernetesPodOperator(
     namespace='airflow',
-    image="ubuntu:16.04",
+    image=f"{repo}:{tag}",  # image="ubuntu:16.04",
+    image_pull_secrets=[k8s.V1LocalObjectReference("dockerhub")],
+    image_pull_policy="Always",
     cmds=["bash", "-cx"],
     arguments=["pwd", "ls"],
     labels={"foo": "bar"},
@@ -23,4 +28,5 @@
     dag=dag
 )
 
+# define DAG pipeline
 (k)