Skip to content

Commit 07c7a68

Browse files
committed
Prevent retries on the concurrency check
1 parent 3c1b886 commit 07c7a68

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

catalog/dags/data_refresh/create_filtered_index_dag.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -141,7 +141,9 @@ def prevent_concurrency_with_data_refresh(**context):
141141
},
142142
render_template_as_native_obj=True,
143143
) as dag:
144-
prevent_concurrency = prevent_concurrency_with_data_refresh()
144+
prevent_concurrency = prevent_concurrency_with_data_refresh.override(
145+
retries=0
146+
)()
145147

146148
# Once the concurrency check has passed, actually create the filtered
147149
# index.

0 commit comments

Comments
 (0)