Skip to content

Commit

Permalink
increase timeouts range in both worker and bundle-manager to help all…
Browse files Browse the repository at this point in the history
…eviate the syncrhonization issue (#4421)
  • Loading branch information
AndrewJGaut authored Mar 5, 2023
1 parent 7833e8e commit 1c634d4
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion codalab/rest/workers.py
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@ def checkin(worker_id):
Waits for a message for the worker for WAIT_TIME_SECS seconds. Returns the
message or None if there isn't one.
"""
WAIT_TIME_SECS = 3.0
WAIT_TIME_SECS = 5.0

# Old workers might not have all the fields, so allow subsets to be missing.
socket_id = local.worker_model.worker_checkin(
Expand Down
2 changes: 1 addition & 1 deletion codalab/server/bundle_manager.py
Original file line number Diff line number Diff line change
Expand Up @@ -355,7 +355,7 @@ def _acknowledge_recently_finished_bundles(self, workers):
worker['socket_id'],
worker['worker_id'],
{'type': 'mark_finalized', 'uuid': bundle.uuid},
0.2,
1,
):
logger.info(
'Acknowledged finalization of run bundle {} on worker {}'.format(
Expand Down

0 comments on commit 1c634d4

Please sign in to comment.