fix: debug log for pending messages count in RedisStreamBroker (#96)

FlorianLB · web-flow · commit 7160ca1f8049 · 2025-07-25T11:28:48.000+02:00
diff --git 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]:

Original file line number	Diff line number	Diff line change
`@@ -310,7 +310,7 @@ async def listen(self) -> AsyncGenerator[AckableMessage, None]:`
`310`	`310`	`)`
`311`	`311`	`logger.debug(`
`312`	`312`	`"Found %d pending messages in stream %s",`
`313`		`- len(pending),`
	`313`	`+ len(pending[1]),`
`314`	`314`	`stream,`
`315`	`315`	`)`
`316`	`316`	`for msg_id, msg in pending[1]:`