diff options
Diffstat (limited to 'shared/src')
| -rw-r--r-- | shared/src/shared/broker.py | 4 |
1 files changed, 1 insertions, 3 deletions
diff --git a/shared/src/shared/broker.py b/shared/src/shared/broker.py index c060c24..fbe4576 100644 --- a/shared/src/shared/broker.py +++ b/shared/src/shared/broker.py @@ -63,9 +63,7 @@ class RedisBroker: count: int = 10, ) -> list[tuple[str, dict[str, Any]]]: """Read pending (unacknowledged) messages for this consumer.""" - results = await self._redis.xreadgroup( - group, consumer, {stream: "0"}, count=count - ) + results = await self._redis.xreadgroup(group, consumer, {stream: "0"}, count=count) messages = [] if results: for _stream, entries in results: |