From 4d5901048fad24a810c5144f00201df3f37918a2 Mon Sep 17 00:00:00 2001 From: romanoa77 <37339804+romanoa77@users.noreply.github.com> Date: Tue, 17 Sep 2024 12:04:54 +0200 Subject: [PATCH] Update dags_airflow_ale_kopfocal.py --- dags_airflow_ale_kopfocal.py | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/dags_airflow_ale_kopfocal.py b/dags_airflow_ale_kopfocal.py index 879f327..6031079 100644 --- a/dags_airflow_ale_kopfocal.py +++ b/dags_airflow_ale_kopfocal.py @@ -33,22 +33,20 @@ Op =KubernetesPodOperator( namespace="glitchflow", - # unique id of the task within the DAG - task_id="kubeop", + # the Docker image to launch image="debian", image_pull_policy="Always", cmds=["bash","-cx"], arguments=["echo","Hello World"], - # launch the Pod on the same cluster as Airflow is running on - in_cluster=True, - # launch the Pod in the same namespace as Airflow is running in + + # Pod configuration # name the Pod name="airflow_op", - - + # launch the Pod on the same cluster as Airflow is running on + in_cluster=True, # attach labels to the Pod, can be used for grouping labels={"app": "preq", "backend": "airflow"}, # reattach to worker instead of creating a new Pod on worker failure @@ -61,6 +59,8 @@ log_events_on_failure=True, # enable xcom do_xcom_push=True, + # unique id of the task within the DAG + task_id="kubeop", dag=dag, #env_vars={"NAME_TO_GREET": f"{name}"},