From ed7b64a2defb8820d2716094599df94ce83f5246 Mon Sep 17 00:00:00 2001 From: gabrielwol <80077912+gabrielwol@users.noreply.github.com> Date: Mon, 3 Feb 2025 14:42:49 +0000 Subject: [PATCH] #1141 none_failed_min_one_success -> none_failed --- dags/miovision_pull.py | 2 +- dags/wys_pull.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/dags/miovision_pull.py b/dags/miovision_pull.py index d56a4a40a..20b47954a 100644 --- a/dags/miovision_pull.py +++ b/dags/miovision_pull.py @@ -91,7 +91,7 @@ def check_partitions(): sql="""SELECT miovision_api.create_mm_nested_volumes_partitions('volumes'::text, '{{ macros.ds_format(ds, '%Y-%m-%d', '%Y') }}'::int, '{{ macros.ds_format(ds, '%Y-%m-%d', '%m') }}'::int)""", conn_id='miovision_api_bot', autocommit=True, - trigger_rule='none_failed_min_one_success' + trigger_rule='none_failed' ) create_annual_partition >> create_month_partition diff --git a/dags/wys_pull.py b/dags/wys_pull.py index 531226d50..6b06147da 100644 --- a/dags/wys_pull.py +++ b/dags/wys_pull.py @@ -77,7 +77,7 @@ def check_partitions(): create_month_partition = SQLExecuteQueryOperator( task_id='create_month_partition', pre_execute=check_1st_of_month, - trigger_rule='none_failed_min_one_success', + trigger_rule='none_failed', sql="SELECT wys.create_mm_nested_raw_data_partitions('{{ macros.ds_format(ds, '%Y-%m-%d', '%Y') }}'::int, '{{ macros.ds_format(ds, '%Y-%m-%d', '%m') }}'::int)", conn_id='wys_bot', autocommit=True