diff --git a/taskiq_redis/redis_broker.py b/taskiq_redis/redis_broker.py
index f16ee52..44b766b 100644
--- a/taskiq_redis/redis_broker.py
+++ b/taskiq_redis/redis_broker.py
@@ -310,7 +310,7 @@ async def listen(self) -> AsyncGenerator[AckableMessage, None]:
                         )
                         logger.debug(
                             "Found %d pending messages in stream %s",
-                            len(pending),
+                            len(pending[1]),
                             stream,
                         )
                         for msg_id, msg in pending[1]: