Skip to content

Commit

Permalink
Update dags_airflow_ale_kopfocal.py
Browse files Browse the repository at this point in the history
  • Loading branch information
romanoa77 authored Sep 17, 2024
1 parent 65f8d0d commit 4d59010
Showing 1 changed file with 7 additions and 7 deletions.
14 changes: 7 additions & 7 deletions dags_airflow_ale_kopfocal.py
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand All @@ -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}"},
Expand Down

0 comments on commit 4d59010

Please sign in to comment.