Update dags_airflow_fede_rucio_k8soperator.py

interTwin-eu · Feb 6, 2024 · eecf429 · eecf429
1 parent 72f6123
commit eecf429
Showing 1 changed file with 18 additions and 1 deletion.
diff --git a/dags_airflow_fede_rucio_k8soperator.py b/dags_airflow_fede_rucio_k8soperator.py
@@ -38,5 +38,22 @@
     dag=dag,
 )
 
+k1 = KubernetesPodOperator(
+    namespace="airflow",
+    image=f"{repo}:{tag}",  # image="ubuntu:16.04",
+    image_pull_secrets=[k8s.V1LocalObjectReference("dockerhub")],
+    # image_pull_policy="Always",
+    cmds=["./get-token.sh"],
+    # cmds=["bash", "-cx"],
+    # arguments=["pwd", "ls"],
+    labels={"foo": "bar"},
+    name="test-data-access-1",
+    task_id="data-access-1",
+    is_delete_operator_pod=False,
+    hostnetwork=False,
+    startup_timeout_seconds=900,
+    dag=dag,
+)
+
 # define DAG pipeline
-(k >> k)
+(k >> k1)