Skip to content

Commit 82e5475

Browse files
committed
Add super.shutdown() call in redis brokers
1 parent 30573da commit 82e5475

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

taskiq_redis/redis_broker.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -49,6 +49,7 @@ def __init__(
4949

5050
async def shutdown(self) -> None:
5151
"""Closes redis connection pool."""
52+
await super().shutdown()
5253
await self.connection_pool.disconnect()
5354

5455
async def listen(self) -> AsyncGenerator[BrokerMessage, None]:

0 commit comments

Comments
 (0)