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.
2 parents 34ceb9d + fa2ec58 commit ab0aa8aCopy full SHA for ab0aa8a
pyproject.toml
@@ -1,6 +1,6 @@
1
[tool.poetry]
2
name = "taskiq-aio-pika"
3
-version = "0.0.8"
+version = "0.0.9"
4
description = "RabbitMQ broker for taskiq"
5
authors = ["Pavel Kirilin <[email protected]>"]
6
readme = "README.md"
taskiq_aio_pika/broker.py
@@ -116,6 +116,7 @@ def __init__( # noqa: WPS211
116
117
async def startup(self) -> None: # noqa: WPS217
118
"""Create exchange and queue on startup."""
119
+ await super().startup()
120
self.write_conn = await connect_robust(
121
self.url,
122
loop=self._loop,
0 commit comments