Skip to content

Commit 16887b1

Browse files
committed
Replace non-logging uses of battery_distribution with battery_ids
This makes it possible to specialize `battery_distribution` to be more suitable for logging. Signed-off-by: Sahas Subramanian <[email protected]>
1 parent f546654 commit 16887b1

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

src/frequenz/sdk/microgrid/_power_distributing/_component_managers/_battery_manager.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -267,8 +267,10 @@ async def _distribute_power(
267267
"""
268268
distributed_power_value = request.power - distribution.remaining_power
269269
battery_distribution: dict[ComponentId, Power] = {}
270+
battery_ids: set[ComponentId] = set()
270271
for inverter_id, dist in distribution.distribution.items():
271272
for battery_id in self._inv_bats_map[inverter_id]:
273+
battery_ids.add(battery_id)
272274
battery_distribution[battery_id] = (
273275
battery_distribution.get(battery_id, Power.zero()) + dist
274276
)
@@ -284,7 +286,7 @@ async def _distribute_power(
284286

285287
response: Success | PartialFailure
286288
if len(failed_batteries) > 0:
287-
succeed_batteries = set(battery_distribution.keys()) - failed_batteries
289+
succeed_batteries = battery_ids - failed_batteries
288290
response = PartialFailure(
289291
request=request,
290292
succeeded_power=distributed_power_value - failed_power,
@@ -294,7 +296,7 @@ async def _distribute_power(
294296
excess_power=distribution.remaining_power,
295297
)
296298
else:
297-
succeed_batteries = set(battery_distribution.keys())
299+
succeed_batteries = battery_ids
298300
response = Success(
299301
request=request,
300302
succeeded_power=distributed_power_value,

0 commit comments

Comments
 (0)