Skip to content

Commit

Permalink
minor update to retry_task_map.py
Browse files Browse the repository at this point in the history
  • Loading branch information
Bodong-Yang authored Jun 6, 2024
1 parent d4018eb commit e42b207
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion src/otaclient_common/retry_task_map.py
Original file line number Diff line number Diff line change
Expand Up @@ -79,7 +79,7 @@ def __init__(
super().__init__(max_workers=max_workers, thread_name_prefix=thread_name_prefix)

def _watchdog() -> None:
"""Watchdog watches exceeding of max_retry and max no_progress_timeout."""
"""Watchdog will shutdown the threadpool on certain conditions being met."""
while not self._shutdown and not concurrent_fut_thread._shutdown:
if self.max_total_retry and self._retry_count > self.max_total_retry:
logger.warning(f"exceed {self.max_total_retry=}, abort")
Expand Down

0 comments on commit e42b207

Please sign in to comment.