Skip to content

Commit 5dcb942

Browse files
llucaxllucax
committed
Adapt formatting to the new black version
Signed-off-by: Leandro Lucarella <[email protected]>
1 parent 6088187 commit 5dcb942

File tree

25 files changed

+235
-215
lines changed

25 files changed

+235
-215
lines changed

‎src/frequenz/sdk/actor/_data_sourcing/microgrid_api_source.py‎

Lines changed: 12 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -164,9 +164,9 @@ async def _check_battery_request(
164164
_logger.error(err)
165165
raise ValueError(err)
166166
if comp_id not in self.comp_data_receivers:
167-
self.comp_data_receivers[
168-
comp_id
169-
] = await connection_manager.get().api_client.battery_data(comp_id)
167+
self.comp_data_receivers[comp_id] = (
168+
await connection_manager.get().api_client.battery_data(comp_id)
169+
)
170170

171171
async def _check_ev_charger_request(
172172
self,
@@ -189,9 +189,9 @@ async def _check_ev_charger_request(
189189
_logger.error(err)
190190
raise ValueError(err)
191191
if comp_id not in self.comp_data_receivers:
192-
self.comp_data_receivers[
193-
comp_id
194-
] = await connection_manager.get().api_client.ev_charger_data(comp_id)
192+
self.comp_data_receivers[comp_id] = (
193+
await connection_manager.get().api_client.ev_charger_data(comp_id)
194+
)
195195

196196
async def _check_inverter_request(
197197
self,
@@ -214,9 +214,9 @@ async def _check_inverter_request(
214214
_logger.error(err)
215215
raise ValueError(err)
216216
if comp_id not in self.comp_data_receivers:
217-
self.comp_data_receivers[
218-
comp_id
219-
] = await connection_manager.get().api_client.inverter_data(comp_id)
217+
self.comp_data_receivers[comp_id] = (
218+
await connection_manager.get().api_client.inverter_data(comp_id)
219+
)
220220

221221
async def _check_meter_request(
222222
self,
@@ -239,9 +239,9 @@ async def _check_meter_request(
239239
_logger.error(err)
240240
raise ValueError(err)
241241
if comp_id not in self.comp_data_receivers:
242-
self.comp_data_receivers[
243-
comp_id
244-
] = await connection_manager.get().api_client.meter_data(comp_id)
242+
self.comp_data_receivers[comp_id] = (
243+
await connection_manager.get().api_client.meter_data(comp_id)
244+
)
245245

246246
async def _check_requested_component_and_metrics(
247247
self,

‎src/frequenz/sdk/actor/_power_managing/_power_managing_actor.py‎

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -221,11 +221,11 @@ async def _run(self) -> None:
221221
).new_sender()
222222
}
223223
elif priority not in self._subscriptions[component_ids]:
224-
self._subscriptions[component_ids][
225-
priority
226-
] = self._channel_registry.get_or_create(
227-
_Report, sub.get_channel_name()
228-
).new_sender()
224+
self._subscriptions[component_ids][priority] = (
225+
self._channel_registry.get_or_create(
226+
_Report, sub.get_channel_name()
227+
).new_sender()
228+
)
229229

230230
if sub.component_ids not in self._bound_tracker_tasks:
231231
self._add_bounds_tracker(sub.component_ids)
@@ -236,9 +236,9 @@ async def _run(self) -> None:
236236
)
237237

238238
result = selected.value
239-
self._distribution_results[
240-
frozenset(result.request.component_ids)
241-
] = result
239+
self._distribution_results[frozenset(result.request.component_ids)] = (
240+
result
241+
)
242242
if not isinstance(result, power_distributing.Success):
243243
_logger.warning(
244244
"PowerManagingActor: PowerDistributing failed: %s", result

‎src/frequenz/sdk/actor/_power_managing/_sorted_set.py‎

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,8 +17,7 @@
1717

1818
class _Comparable(typing.Protocol):
1919
@abc.abstractmethod
20-
def __lt__(self: _C, other: _C, /) -> bool:
21-
...
20+
def __lt__(self: _C, other: _C, /) -> bool: ...
2221

2322

2423
_ComparableT = typing.TypeVar("_ComparableT", bound=_Comparable)

‎src/frequenz/sdk/actor/_resampling.py‎

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -49,12 +49,12 @@ def __init__( # pylint: disable=too-many-arguments
4949
"""
5050
super().__init__(name=name)
5151
self._channel_registry: ChannelRegistry = channel_registry
52-
self._data_sourcing_request_sender: Sender[
53-
ComponentMetricRequest
54-
] = data_sourcing_request_sender
55-
self._resampling_request_receiver: Receiver[
56-
ComponentMetricRequest
57-
] = resampling_request_receiver
52+
self._data_sourcing_request_sender: Sender[ComponentMetricRequest] = (
53+
data_sourcing_request_sender
54+
)
55+
self._resampling_request_receiver: Receiver[ComponentMetricRequest] = (
56+
resampling_request_receiver
57+
)
5858
self._resampler: Resampler = Resampler(config)
5959
self._active_req_channels: set[str] = set()
6060

‎src/frequenz/sdk/actor/power_distributing/_distribution_algorithm/_battery_distribution_algorithm.py‎

Lines changed: 12 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -790,12 +790,12 @@ def _inclusion_exclusion_bounds(
790790
excl_bounds: dict[int, float] = {}
791791
for battery, inverters in components:
792792
if supply:
793-
excl_bounds[
794-
battery.component_id
795-
] = -battery.power_bounds.exclusion_lower
796-
incl_bounds[
797-
battery.component_id
798-
] = -battery.power_bounds.inclusion_lower
793+
excl_bounds[battery.component_id] = (
794+
-battery.power_bounds.exclusion_lower
795+
)
796+
incl_bounds[battery.component_id] = (
797+
-battery.power_bounds.inclusion_lower
798+
)
799799
else:
800800
excl_bounds[battery.component_id] = battery.power_bounds.exclusion_upper
801801
incl_bounds[battery.component_id] = battery.power_bounds.inclusion_upper
@@ -806,16 +806,16 @@ def _inclusion_exclusion_bounds(
806806
inverter.active_power_inclusion_lower_bound,
807807
battery.power_bounds.inclusion_lower,
808808
)
809-
excl_bounds[
810-
inverter.component_id
811-
] = -inverter.active_power_exclusion_lower_bound
809+
excl_bounds[inverter.component_id] = (
810+
-inverter.active_power_exclusion_lower_bound
811+
)
812812

813813
else:
814814
incl_bounds[inverter.component_id] = min(
815815
inverter.active_power_inclusion_upper_bound,
816816
battery.power_bounds.inclusion_upper,
817817
)
818-
excl_bounds[
819-
inverter.component_id
820-
] = inverter.active_power_exclusion_upper_bound
818+
excl_bounds[inverter.component_id] = (
819+
inverter.active_power_exclusion_upper_bound
820+
)
821821
return incl_bounds, excl_bounds

‎src/frequenz/sdk/timeseries/_base_types.py‎

Lines changed: 4 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -65,12 +65,10 @@ def __iter__(self) -> Iterator[QuantityT | None]:
6565
yield self.value_p3
6666

6767
@overload
68-
def max(self, default: QuantityT) -> QuantityT:
69-
...
68+
def max(self, default: QuantityT) -> QuantityT: ...
7069

7170
@overload
72-
def max(self, default: None = None) -> QuantityT | None:
73-
...
71+
def max(self, default: None = None) -> QuantityT | None: ...
7472

7573
def max(self, default: QuantityT | None = None) -> QuantityT | None:
7674
"""Return the max value among all phases, or default if they are all `None`.
@@ -90,12 +88,10 @@ def max(self, default: QuantityT | None = None) -> QuantityT | None:
9088
return value
9189

9290
@overload
93-
def min(self, default: QuantityT) -> QuantityT:
94-
...
91+
def min(self, default: QuantityT) -> QuantityT: ...
9592

9693
@overload
97-
def min(self, default: None = None) -> QuantityT | None:
98-
...
94+
def min(self, default: None = None) -> QuantityT | None: ...
9995

10096
def min(self, default: QuantityT | None = None) -> QuantityT | None:
10197
"""Return the min value among all phases, or default if they are all `None`.

‎src/frequenz/sdk/timeseries/_grid_frequency.py‎

Lines changed: 10 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -69,9 +69,9 @@ def __init__(
6969
),
7070
)
7171

72-
self._request_sender: Sender[
73-
ComponentMetricRequest
74-
] = data_sourcing_request_sender
72+
self._request_sender: Sender[ComponentMetricRequest] = (
73+
data_sourcing_request_sender
74+
)
7575
self._channel_registry: ChannelRegistry = channel_registry
7676
self._source_component: Component = source
7777
self._component_metric_request: ComponentMetricRequest = create_request(
@@ -107,9 +107,13 @@ def new_receiver(self) -> Receiver[Sample[Frequency]]:
107107
)
108108

109109
return receiver.map(
110-
lambda sample: Sample[Frequency](sample.timestamp, None)
111-
if sample.value is None or sample.value.isnan()
112-
else Sample(sample.timestamp, Frequency.from_hertz(sample.value.base_value))
110+
lambda sample: (
111+
Sample[Frequency](sample.timestamp, None)
112+
if sample.value is None or sample.value.isnan()
113+
else Sample(
114+
sample.timestamp, Frequency.from_hertz(sample.value.base_value)
115+
)
116+
)
113117
)
114118

115119
async def _send_request(self) -> None:

‎src/frequenz/sdk/timeseries/_voltage_streamer.py‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -178,9 +178,9 @@ async def _send_request(self) -> None:
178178
msg = Sample3Phase(
179179
phases[0].timestamp,
180180
*map(
181-
lambda p: Voltage.from_volts(p.value.base_value)
182-
if p.value
183-
else None,
181+
lambda p: (
182+
Voltage.from_volts(p.value.base_value) if p.value else None
183+
),
184184
phases,
185185
),
186186
)

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

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -385,10 +385,10 @@ def power_status(self) -> ReceiverFetcher[BatteryPoolReport]:
385385
priority=self._priority,
386386
component_ids=self._battery_pool._batteries,
387387
)
388-
self._battery_pool._power_bounds_subs[
389-
sub.get_channel_name()
390-
] = asyncio.create_task(
391-
self._battery_pool._power_manager_bounds_subscription_sender.send(sub)
388+
self._battery_pool._power_bounds_subs[sub.get_channel_name()] = (
389+
asyncio.create_task(
390+
self._battery_pool._power_manager_bounds_subscription_sender.send(sub)
391+
)
392392
)
393393
channel = self._battery_pool._channel_registry.get_or_create(
394394
_power_managing._Report, sub.get_channel_name()

‎src/frequenz/sdk/timeseries/battery_pool/_battery_pool_reference_store.py‎

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -92,13 +92,13 @@ def __init__( # pylint: disable=too-many-arguments
9292

9393
self._min_update_interval: timedelta = min_update_interval
9494

95-
self._power_manager_requests_sender: Sender[
96-
Proposal
97-
] = power_manager_requests_sender
95+
self._power_manager_requests_sender: Sender[Proposal] = (
96+
power_manager_requests_sender
97+
)
9898

99-
self._power_manager_bounds_subscription_sender: Sender[
100-
ReportRequest
101-
] = power_manager_bounds_subscription_sender
99+
self._power_manager_bounds_subscription_sender: Sender[ReportRequest] = (
100+
power_manager_bounds_subscription_sender
101+
)
102102

103103
self._active_methods: dict[str, MetricAggregator[Any]] = {}
104104
self._power_bounds_subs: dict[str, asyncio.Task[None]] = {}

0 commit comments

Comments
 (0)