diff --git a/taskiq_aio_pika/broker.py b/taskiq_aio_pika/broker.py index d4a392e..9cb591b 100644 --- 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,