From fd4f1af36b3b27597a7aef953dc5da3ecfd5df2b Mon Sep 17 00:00:00 2001
From: "bodong.yang" <bodong.yang@tier4.jp>
Date: Mon, 24 Jun 2024 02:08:23 +0000
Subject: [PATCH] always release se first

---
 src/otaclient_common/retry_task_map.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/otaclient_common/retry_task_map.py b/src/otaclient_common/retry_task_map.py
index 39f546f4d..221fc9521 100644
--- 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():