Only send currently active dispatches to new receivers.

Marenz · Marenz · commit 62d36fd26e5b · 2025-02-28T15:17:57.000+01:00
Signed-off-by: Mathias L. Baumann &lt;mathias.baumann@frequenz.com&gt;
diff --git a/src/frequenz/dispatch/_bg_service.py b/src/frequenz/dispatch/_bg_service.py
@@ -212,7 +212,8 @@ async def new_running_state_event_receiver(
             )
 
         for dispatch in dispatches:
-            await self._send_running_state_change(dispatch)
+            if dispatch.started:
+                await self._send_running_state_change(dispatch)
 
         return receiver
 

Original file line number	Diff line number	Diff line change
`@@ -212,7 +212,8 @@ async def new_running_state_event_receiver(`
`212`	`212`	`)`
`213`	`213`
`214`	`214`	`for dispatch in dispatches:`
`215`		`- await self._send_running_state_change(dispatch)`
	`215`	`+ if dispatch.started:`
	`216`	`+ await self._send_running_state_change(dispatch)`
`216`	`217`
`217`	`218`	`return receiver`
`218`	`219`