fix: RecursionError log msg when queue is broken (#509)

BobTheBuidler · Jan 6, 2025 · cd7cdfa · cd7cdfa
1 parent cb17e69
commit cd7cdfa
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/a_sync/primitives/queue.py b/a_sync/primitives/queue.py
@@ -253,11 +253,11 @@ def get_multi_nowait(self, i: int, can_return_less: bool = False) -> List[T]:
 
 def log_broken(func: Callable[[Any], NoReturn]) -> Callable[[Any], NoReturn]:
     @wraps(func)
-    async def __worker_exc_wrap(self):
+    async def __worker_exc_wrap(self: "ProcessingQueue"):
         try:
             return await func(self)
         except Exception as e:
-            logger.error("%s for %s is broken!!!", type(self).__name__, func)
+            logger.error("%s for %s is broken!!!", type(self).__name__, self.func)
             logger.exception(e)
             raise