use recursive lock to allow sending another task while processing the…

… task in worker
cenkalti · Dec 6, 2023 · f825b6f · f825b6f
1 parent 1f3ed77
commit f825b6f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/kuyruk/connection.py b/kuyruk/connection.py
@@ -48,7 +48,7 @@ def __init__(self,
         self._tcp_user_timeout = tcp_user_timeout
 
         self._connection: amqp.Connection = None
-        self._lock = threading.Lock()
+        self._lock = threading.RLock()
         self._heartbeat_thread: Optional[threading.Thread] = None
         self._stop_heartbeat = threading.Event()
         self._last_used_at: float = 0  # Time of last connection used at in monotonic time