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.
1 parent 282ba6a commit c5b8200Copy full SHA for c5b8200
1 file changed
taskiq/abc/broker.py
@@ -132,6 +132,8 @@ async def startup(self) -> None:
132
for handler in self.event_handlers[event]:
133
await maybe_awaitable(handler(self.state))
134
135
+ await self.result_backend.startup()
136
+
137
async def shutdown(self) -> None:
138
"""
139
Close the broker.
@@ -147,6 +149,8 @@ async def shutdown(self) -> None:
147
149
148
150
151
152
+ await self.result_backend.shutdown()
153
154
@abstractmethod
155
async def kick(
156
self,
0 commit comments