always release se first

tier4 · Jun 24, 2024 · fd4f1af · fd4f1af
1 parent 32bae00
commit fd4f1af
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/otaclient_common/retry_task_map.py b/src/otaclient_common/retry_task_map.py
@@ -109,8 +109,8 @@ def _watchdog(
     def _task_done_cb(
         self, fut: Future[Any], /, *, item: T, func: Callable[[T], Any]
     ) -> None:
+        self._concurrent_semaphore.release()  # always release se first
         self._fut_queue.put_nowait(fut)
-        self._concurrent_semaphore.release()
 
         # ------ on task succeeded ------ #
         if not fut.exception():