Added training DAG

interTwin-eu · Jul 7, 2024 · 5adf44d · 5adf44d
1 parent 19727a2
commit 5adf44d
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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)