From eecf429ee3c866cb8af771cb1ef5906c1064c633 Mon Sep 17 00:00:00 2001 From: leggerf <41438017+leggerf@users.noreply.github.com> Date: Tue, 6 Feb 2024 12:40:57 +0100 Subject: [PATCH] Update dags_airflow_fede_rucio_k8soperator.py --- dags_airflow_fede_rucio_k8soperator.py | 19 ++++++++++++++++++- 1 file changed, 18 insertions(+), 1 deletion(-) diff --git a/dags_airflow_fede_rucio_k8soperator.py b/dags_airflow_fede_rucio_k8soperator.py index 8e23384..f310b7e 100644 --- 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)