Merge pull request #9 from taskiq-python/feature/startup

Added super().startup() call on startup.
taskiq-python · Sep 17, 2022 · 50b1346 · 50b1346
2 parents 900af1f + 9b9ce09
commit 50b1346
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/taskiq_aio_pika/broker.py b/taskiq_aio_pika/broker.py
@@ -116,6 +116,7 @@ def __init__(  # noqa: WPS211
 
     async def startup(self) -> None:  # noqa: WPS217
         """Create exchange and queue on startup."""
+        await super().startup()
         self.write_conn = await connect_robust(
             self.url,
             loop=self._loop,