Make ComponentPool.system_power_bounds public

Signed-off-by: Simon Völcker <simon.voelcker@frequenz.com>

Author: simonvoelcker

examples/battery_pool.py

@@ -30,8 +30,7 @@ async def main() -> None:
     receivers = [
         battery_pool.soc.new_receiver(limit=1),
         battery_pool.capacity.new_receiver(limit=1),
-        # pylint: disable-next=protected-access
-        battery_pool._system_power_bounds.new_receiver(limit=1),
+        battery_pool.system_power_bounds.new_receiver(limit=1),
     ]
 
     async for metric in merge(*receivers):

src/frequenz/sdk/microgrid/_power_managing/_power_managing_actor.py

@@ -149,20 +149,17 @@ def _add_system_bounds_tracker(self, component_ids: frozenset[ComponentId]) -> N
             battery_pool = _data_pipeline.new_battery_pool(
                 priority=-sys.maxsize - 1, component_ids=component_ids
             )
-            # pylint: disable-next=protected-access
-            bounds_receiver = battery_pool._system_power_bounds.new_receiver()
+            bounds_receiver = battery_pool.system_power_bounds.new_receiver()
         elif issubclass(self._component_class, EvCharger):
             ev_charger_pool = _data_pipeline.new_ev_charger_pool(
                 priority=-sys.maxsize - 1, component_ids=component_ids
             )
-            # pylint: disable-next=protected-access
-            bounds_receiver = ev_charger_pool._system_power_bounds.new_receiver()
+            bounds_receiver = ev_charger_pool.system_power_bounds.new_receiver()
         elif issubclass(self._component_class, SolarInverter):
             pv_pool = _data_pipeline.new_pv_pool(
                 priority=-sys.maxsize - 1, component_ids=component_ids
             )
-            # pylint: disable-next=protected-access
-            bounds_receiver = pv_pool._system_power_bounds.new_receiver()
+            bounds_receiver = pv_pool.system_power_bounds.new_receiver()
         else:
             _logger.error(
                 "PowerManagingActor: Unsupported component class: %s",

src/frequenz/sdk/timeseries/battery_pool/_battery_pool.py

@@ -258,7 +258,7 @@ def capacity(self) -> ReceiverFetcher[Sample[Energy]]:
 
     @override
     @property
-    def _system_power_bounds(self) -> ReceiverFetcher[SystemBounds]:
+    def system_power_bounds(self) -> ReceiverFetcher[SystemBounds]:
         """Get receiver to receive new power bounds when they change.
 
         Power bounds refer to the min and max power that a battery can

src/frequenz/sdk/timeseries/component_pool/_component_pool.py

@@ -146,7 +146,7 @@ def power_distribution_results(self) -> ReceiverFetcher[_power_distributing.Resu
         )
 
     @property
-    def _system_power_bounds(self) -> ReceiverFetcher[SystemBounds]:
+    def system_power_bounds(self) -> ReceiverFetcher[SystemBounds]:
         """Return a receiver fetcher for the system power bounds."""
         return self._pool_ref_store.bounds_channel
 

tests/timeseries/_battery_pool/test_battery_pool.py

@@ -902,9 +902,7 @@ async def run_power_bounds_test(  # pylint: disable=too-many-locals
                 sampling_rate=0.1,
             )
 
-    # pylint: disable=protected-access
-    receiver = battery_pool._system_power_bounds.new_receiver(limit=50)
-    # pylint: enable=protected-access
+    receiver = battery_pool.system_power_bounds.new_receiver(limit=50)
 
     # First metrics delivers slower because of the startup delay in the pool.
     msg = await asyncio.wait_for(