From 319d542b6d4d6a1608793f1e687728875c6768b1 Mon Sep 17 00:00:00 2001 From: ChinoUkaegbu <77782533+ChinoUkaegbu@users.noreply.github.com> Date: Wed, 28 Aug 2024 18:57:42 +0400 Subject: [PATCH] update timeouts in constants.py (#4818) --- catalog/dags/database/batched_update/constants.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/catalog/dags/database/batched_update/constants.py b/catalog/dags/database/batched_update/constants.py index 8bc8d3c86d2..6f64b61da72 100644 --- a/catalog/dags/database/batched_update/constants.py +++ b/catalog/dags/database/batched_update/constants.py @@ -8,9 +8,9 @@ SLACK_ICON = ":database:" DEFAULT_BATCH_SIZE = 10_000 -DAGRUN_TIMEOUT = timedelta(days=31 * 3) SELECT_TIMEOUT = timedelta(hours=24) -UPDATE_TIMEOUT = timedelta(days=30 * 3) # 3 months +UPDATE_TIMEOUT = timedelta(days=30) # 1 month +DAGRUN_TIMEOUT = UPDATE_TIMEOUT + SELECT_TIMEOUT # Task IDs used for branching operator GET_EXPECTED_COUNT_TASK_ID = "get_expected_update_count"