Skip to content

Commit 8f42e51

Browse files
committed
Properly start/stop timer in DispatchScheduler
Signed-off-by: Mathias L. Baumann <mathias.baumann@frequenz.com>
1 parent 76da703 commit 8f42e51

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

src/frequenz/dispatch/_bg_service.py

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@
2020
from frequenz.client.dispatch import DispatchApiClient
2121
from frequenz.client.dispatch.types import Event
2222
from frequenz.sdk.actor import BackgroundService
23+
from typing_extensions import override
2324

2425
from ._dispatch import Dispatch
2526
from ._event import Created, Deleted, DispatchEvent, Updated
@@ -219,8 +220,15 @@ async def new_running_state_event_receiver(
219220

220221
# pylint: enable=redefined-builtin
221222

223+
@override
224+
async def stop(self, msg: str | None = None) -> None:
225+
"""Stop the background service."""
226+
self._next_event_timer.close()
227+
await super().stop(msg)
228+
222229
def start(self) -> None:
223230
"""Start the background service."""
231+
self._next_event_timer.reset(interval=timedelta(seconds=1))
224232
self._tasks.add(asyncio.create_task(self._run()))
225233

226234
async def _run(self) -> None:

0 commit comments

Comments
 (0)