Update bound-streaming channels to resend latest to new receivers

The `SystemBoundsTracker`s send out a new value only when there's a change in the system bounds. This means when a new receiver is created, it could wait for a long time before receiving the bounds. This change allows new receivers to get the latest state when requested. This is already the case for battery bounds, and needed only for PV and EV charger bounds. Signed-off-by: Sahas Subramanian <[email protected]>
shsms · Nov 8, 2024 · 66f01dd · 66f01dd
1 parent 998ebff
commit 66f01dd
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/src/frequenz/sdk/timeseries/ev_charger_pool/_ev_charger_pool_reference_store.py b/src/frequenz/sdk/timeseries/ev_charger_pool/_ev_charger_pool_reference_store.py
@@ -93,7 +93,8 @@ def __init__(  # pylint: disable=too-many-arguments
         )
 
         self.bounds_channel: Broadcast[SystemBounds] = Broadcast(
-            name=f"System Bounds for EV Chargers: {component_ids}"
+            name=f"System Bounds for EV Chargers: {component_ids}",
+            resend_latest=True,
         )
         self.bounds_tracker: EVCSystemBoundsTracker = EVCSystemBoundsTracker(
             self.component_ids,

diff --git a/src/frequenz/sdk/timeseries/pv_pool/_pv_pool_reference_store.py b/src/frequenz/sdk/timeseries/pv_pool/_pv_pool_reference_store.py
@@ -94,7 +94,8 @@ def __init__(  # pylint: disable=too-many-arguments
             self.resampler_subscription_sender,
         )
         self.bounds_channel: Broadcast[SystemBounds] = Broadcast(
-            name=f"System Bounds for PV inverters: {component_ids}"
+            name=f"System Bounds for PV inverters: {component_ids}",
+            resend_latest=True,
         )
         self.bounds_tracker: PVSystemBoundsTracker = PVSystemBoundsTracker(
             self.component_ids,