Merge branch 'release/0.0.9'

Author: s3rius

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "taskiq-aio-pika"
-version = "0.0.8"
+version = "0.0.9"
 description = "RabbitMQ broker for taskiq"
 authors = ["Pavel Kirilin <[email protected]>"]
 readme = "README.md"

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,