Skip to content

Commit b0990e5

Browse files
committed
Make sure we don't overwrite newer dispatches in fetch()
Signed-off-by: Mathias L. Baumann <[email protected]>
1 parent 0bb5873 commit b0990e5

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/frequenz/dispatch/_bg_service.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -359,7 +359,7 @@ async def _fetch(self, timer: Timer) -> None:
359359
dispatch, None, timer
360360
)
361361
await self._lifecycle_events_tx.send(Created(dispatch=dispatch))
362-
elif dispatch.update_time != old_dispatch.update_time:
362+
elif dispatch.update_time > old_dispatch.update_time:
363363
_logger.debug("Updated dispatch: %s", dispatch)
364364
await self._update_dispatch_schedule_and_notify(
365365
dispatch, old_dispatch, timer

0 commit comments

Comments
 (0)