Skip to content

Commit d06291e

Browse files
committed
Delete actors after stopping them
Signed-off-by: Mathias L. Baumann <[email protected]>
1 parent 9faa88b commit d06291e

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

src/frequenz/dispatch/_actor_dispatcher.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -282,6 +282,8 @@ async def _stop_actor(self, stopping_dispatch: Dispatch, msg: str) -> None:
282282

283283
if actor:
284284
await actor.stop(msg)
285+
286+
del self._actors[identity]
285287
else:
286288
_logger.warning(
287289
"Actor for dispatch type %r is not running", stopping_dispatch.type

0 commit comments

Comments
 (0)