From f61bfb18a9672d806d1a5d512874e42c91c236e0 Mon Sep 17 00:00:00 2001 From: Yash Bhardwaj Date: Wed, 10 Aug 2022 14:46:06 +0530 Subject: [PATCH] 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' --- ext/scheduler/airflow2/resources/base_dag.py | 2 +- ext/scheduler/airflow2/resources/expected_compiled_template.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/ext/scheduler/airflow2/resources/base_dag.py b/ext/scheduler/airflow2/resources/base_dag.py index f8b11ab21b..182f708bd5 100644 --- 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 index ac5ad3f987..e47287e977 100644 --- 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 )