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 9747b15 commit 7d43537Copy full SHA for 7d43537
src/frequenz/dispatch/_dispatcher.py
@@ -212,6 +212,8 @@ async def wait(self) -> None:
212
"""Wait until all actor dispatches are stopped."""
213
await asyncio.gather(self._bg_service.wait(), self._empty_event.wait())
214
215
+ self._actor_dispatchers.clear()
216
+
217
@override
218
def cancel(self, msg: str | None = None) -> None:
219
"""Stop the local dispatch service."""
@@ -220,8 +222,6 @@ def cancel(self, msg: str | None = None) -> None:
220
222
for instance in self._actor_dispatchers.values():
221
223
instance.cancel()
224
- self._actor_dispatchers.clear()
-
225
async def start_dispatching(
226
self,
227
dispatch_type: str,
0 commit comments