From 5adf44d0b10b5e3c349722d576937003e936f1db Mon Sep 17 00:00:00 2001 From: Alessio Romano Date: Sun, 7 Jul 2024 19:15:49 +0200 Subject: [PATCH] Added training DAG --- dags_airflow_ale_trainmod.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/dags_airflow_ale_trainmod.py b/dags_airflow_ale_trainmod.py index 3e3232f..4f4460d 100644 --- a/dags_airflow_ale_trainmod.py +++ b/dags_airflow_ale_trainmod.py @@ -95,7 +95,7 @@ def check_response(response): response_check=lambda response: check_response(response), poke_interval=10, timeout=3600, - #mode="reschedule", + mode="reschedule", dag=dag ) @@ -121,7 +121,7 @@ def check_response(response): -join_branch = DummyOperator(task_id="join_brc", dag=dag) +join_branch = DummyOperator(task_id="join_brc",trigger_rule="none_failed", dag=dag) list_proc = DummyOperator(task_id="listen_preproc", dag=dag)