We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 5dd9af6 commit 9b109ddCopy full SHA for 9b109dd
1 file changed
src/otaclient_common/retry_task_map.py
@@ -75,6 +75,7 @@ def __init__(
75
backoff_max: float = 1,
76
) -> None:
77
self._rtm_start_lock = threading.Lock()
78
+ # NOTE: ThreadPoolExecutor itself also has a _shutdown_lock!
79
self._rtm_shutdown_lock = threading.Lock()
80
self._rtm_started = False
81
self._total_task_num = 0
0 commit comments