Update queue.py

BobTheBuidler · Dec 19, 2024 · 34f8cf2 · 34f8cf2
1 parent 75576be
commit 34f8cf2
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/a_sync/primitives/queue.py b/a_sync/primitives/queue.py
@@ -255,7 +255,7 @@ def log_broken(func: Callable[[Any], NoReturn]) -> Callable[[Any], NoReturn]:
     @wraps(func)
     async def __worker_exc_wrap(self):
         try:
-            return func(self)
+            return await func(self)
         except Exception as e:
             logger.error("%s for %s is broken!!!", type(self).__name__, func)
             logger.exception(e)