Only send currently active dispatches to new receivers.

Marenz · Marenz · commit cd82b5574a56 · 2025-02-24T18:09:35.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
@@ -220,7 +220,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
`@@ -220,7 +220,8 @@ async def new_running_state_event_receiver(`
`220`	`220`	`)`
`221`	`221`
`222`	`222`	`for dispatch in dispatches:`
`223`		`- await self._send_running_state_change(dispatch)`
	`223`	`+ if dispatch.started:`
	`224`	`+ await self._send_running_state_change(dispatch)`
`224`	`225`
`225`	`226`	`return receiver`
`226`	`227`