Skip to content

Commit 7e1789a

Browse files
committed
Properly clean up timer in stop()
Signed-off-by: Mathias L. Baumann <[email protected]>
1 parent bd3e59e commit 7e1789a

File tree

1 file changed

+7
-0
lines changed

1 file changed

+7
-0
lines changed

src/frequenz/dispatch/_bg_service.py

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -26,6 +26,7 @@
2626
from frequenz.client.dispatch.types import DispatchEvent as ApiDispatchEvent
2727
from frequenz.client.dispatch.types import Event
2828
from frequenz.sdk.actor import BackgroundService
29+
from typing_extensions import override
2930

3031
from ._dispatch import Dispatch
3132
from ._event import Created, Deleted, DispatchEvent, Updated
@@ -225,6 +226,12 @@ async def new_running_state_event_receiver(
225226

226227
# pylint: enable=redefined-builtin
227228

229+
@override
230+
async def stop(self, msg: str | None = None) -> None:
231+
"""Stop the background service."""
232+
self._next_event_timer.stop()
233+
await super().stop(msg)
234+
228235
def start(self) -> None:
229236
"""Start the background service."""
230237
self._tasks.add(asyncio.create_task(self._run()))

0 commit comments

Comments
 (0)