diff options
| author | TheSiahxyz <164138827+TheSiahxyz@users.noreply.github.com> | 2026-04-01 17:57:43 +0900 |
|---|---|---|
| committer | TheSiahxyz <164138827+TheSiahxyz@users.noreply.github.com> | 2026-04-01 17:57:43 +0900 |
| commit | 61b2a193e79d74783bb1ad4c3a8ccb6ead0f24c0 (patch) | |
| tree | 374ad93df6d393715809192ff40b1754d56de39b /shared/src | |
| parent | 13a9b2c80bb3eb1353cf2d49bdbf7d0dbd858ccc (diff) | |
fix: lint cleanup after medium priority tasks
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: |