Update dags_airflow_ale_kopfocal.py

interTwin-eu · Sep 16, 2024 · 1b40264 · 1b40264
1 parent dad0c0d
commit 1b40264
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/dags_airflow_ale_kopfocal.py b/dags_airflow_ale_kopfocal.py
@@ -35,7 +35,8 @@
         # unique id of the task within the DAG
         task_id="kubeop",
         # the Docker image to launch
-        image="ubuntu",
+        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
@@ -52,7 +53,7 @@
         # reattach to worker instead of creating a new Pod on worker failure
         reattach_on_restart=True,
         # delete Pod after the task is finished
-        is_delete_operator_pod=False,
+        is_delete_operator_pod=True,
         # get log stdout of the container as task logs
         get_logs=True,
         # log events in case of Pod failure