We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 30573da commit 82e5475Copy full SHA for 82e5475
taskiq_redis/redis_broker.py
@@ -49,6 +49,7 @@ def __init__(
49
50
async def shutdown(self) -> None:
51
"""Closes redis connection pool."""
52
+ await super().shutdown()
53
await self.connection_pool.disconnect()
54
55
async def listen(self) -> AsyncGenerator[BrokerMessage, None]:
0 commit comments