Merge pull request #32 from booqoffsky/issue-29

s3rius · web-flow · commit 9cf7146bfa4f · 2023-03-28T15:55:04.000+04:00
Add super.shutdown() call in redis brokers
diff --git a/taskiq_redis/redis_broker.py b/taskiq_redis/redis_broker.py
@@ -49,6 +49,7 @@ def __init__(
 
     async def shutdown(self) -> None:
         """Closes redis connection pool."""
+        await super().shutdown()
         await self.connection_pool.disconnect()
 
     async def listen(self) -> AsyncGenerator[BrokerMessage, None]:
