@@ -219,7 +219,7 @@ def __init__(
219219 self ._battery_receivers : dict [int , Peekable [BatteryData ]] = {}
220220 self ._inverter_receivers : dict [int , Peekable [InverterData ]] = {}
221221
222- self ._all_battery_status = ComponentPoolStatusTracker (
222+ self ._component_pool_status_tracker = ComponentPoolStatusTracker (
223223 component_ids = set (self ._bat_invs_map .keys ()),
224224 component_status_sender = battery_status_sender ,
225225 max_blocking_duration_sec = 30.0 ,
@@ -372,7 +372,7 @@ async def _run(self) -> None: # pylint: disable=too-many-locals
372372
373373 asyncio .gather (
374374 * [
375- self ._all_battery_status .update_status (
375+ self ._component_pool_status_tracker .update_status (
376376 succeed_batteries , failed_batteries
377377 ),
378378 self ._result_sender .send (response ),
@@ -506,7 +506,9 @@ def _get_components_data(self, batteries: abc.Set[int]) -> list[InvBatPair]:
506506 """
507507 pairs_data : list [InvBatPair ] = []
508508
509- working_batteries = self ._all_battery_status .get_working_components (batteries )
509+ working_batteries = self ._component_pool_status_tracker .get_working_components (
510+ batteries
511+ )
510512
511513 for battery_id in working_batteries :
512514 if battery_id not in self ._battery_receivers :
@@ -708,5 +710,5 @@ async def stop(self, msg: str | None = None) -> None:
708710 Args:
709711 msg: The message to be passed to the tasks being cancelled.
710712 """
711- await self ._all_battery_status .stop ()
713+ await self ._component_pool_status_tracker .stop ()
712714 await super ().stop (msg )
0 commit comments