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)