fix: job_end_event trigger set to all_success (#510)

* fix: set publish_job_end_event trigger to 'all_success' * fix: set publish_job_end_event trigger to 'all_success'
raystack · Aug 10, 2022 · f61bfb1 · f61bfb1
1 parent fe3bb2a
commit f61bfb1
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/ext/scheduler/airflow2/resources/base_dag.py b/ext/scheduler/airflow2/resources/base_dag.py
@@ -81,7 +81,7 @@
         task_id = JOB_END_EVENT_NAME,
         python_callable = log_job_end,
         provide_context=True,
-        trigger_rule= 'all_done',
+        trigger_rule= 'all_success',
         dag=dag
     )
 

diff --git a/ext/scheduler/airflow2/resources/expected_compiled_template.py b/ext/scheduler/airflow2/resources/expected_compiled_template.py
@@ -73,7 +73,7 @@
         task_id = JOB_END_EVENT_NAME,
         python_callable = log_job_end,
         provide_context=True,
-        trigger_rule= 'all_done',
+        trigger_rule= 'all_success',
         dag=dag
     )