diff --git a/a_sync/primitives/queue.py b/a_sync/primitives/queue.py
index 59fbc95c..4fab3ea5 100644
--- a/a_sync/primitives/queue.py
+++ b/a_sync/primitives/queue.py
@@ -257,7 +257,7 @@ 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__, self.func)
+            logger.error("%s is broken!!!", self)
             logger.exception(e)
             raise