Skip to content

Commit

Permalink
update timeouts in constants.py (#4818)
Browse files Browse the repository at this point in the history
  • Loading branch information
ChinoUkaegbu authored Aug 28, 2024
1 parent adeb2dd commit 319d542
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions catalog/dags/database/batched_update/constants.py
Original file line number Diff line number Diff line change
Expand Up @@ -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"
Expand Down

0 comments on commit 319d542

Please sign in to comment.