Update dags_airflow_fede_rucio_k8soperator.py

interTwin-eu · Feb 1, 2024 · 0cdc639 · 0cdc639
1 parent 4556df9
commit 0cdc639
Showing 1 changed file with 7 additions and 1 deletion.
diff --git 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)