From 9b9ce09cd2af13de011ffe93c938fd036be3596b Mon Sep 17 00:00:00 2001 From: Pavel Kirilin Date: Sat, 17 Sep 2022 16:43:10 +0400 Subject: [PATCH] Added super().startup() call on startup. Signed-off-by: Pavel Kirilin --- taskiq_aio_pika/broker.py | 1 + 1 file changed, 1 insertion(+) 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,