From 9629df0f0c1d424e3ad913171354e8a1853ec9ba Mon Sep 17 00:00:00 2001 From: Florian Lonqueu-Brochard Date: Sat, 28 Jun 2025 17:56:27 +0200 Subject: [PATCH] fix: debug log for pending messages count in RedisStreamBroker --- taskiq_redis/redis_broker.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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]: