We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 900af1f commit 9b9ce09Copy full SHA for 9b9ce09
1 file changed
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