#1141 none_failed_min_one_success -> none_failed

CityofToronto · Feb 3, 2025 · ed7b64a · ed7b64a
1 parent 268f8b9
commit ed7b64a
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git 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
@@ -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