Format code with black

Signed-off-by: ela-kotulska-frequenz <[email protected]>

Author: ela-kotulska-frequenz

examples/resampling.py

@@ -108,6 +108,7 @@ async def run() -> None:  # pylint: disable=too-many-locals
     second_stage_resampler.add_timeseries(average_chan.new_receiver(), _print_sample)
 
     average_sender = average_chan.new_sender()
+
     # Needed until channels Senders raises exceptions on errors
     async def sink_adapter(sample: Sample) -> None:
         assert await average_sender.send(sample)

src/frequenz/sdk/_data_handling/time_series.py

@@ -478,7 +478,6 @@ def evaluate(
 
             # Symbol metadata is not available, e.g. component category
             if symbol_mapping is None:
-
                 # Component data is available and up to date
                 if cache_lookup_result.entry is not None:
                     kwargs[symbol] = cache_lookup_result.entry.value

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

@@ -347,7 +347,7 @@ async def _handle_data_stream(
 
         def process_msg(data: Any) -> None:
             tasks = []
-            for (extractor, senders) in stream_senders:
+            for extractor, senders in stream_senders:
                 for sender in senders:
                     tasks.append(sender.send(Sample(data.timestamp, extractor(data))))
             asyncio.gather(*tasks)

tests/actor/test_power_distributing.py

@@ -386,7 +386,6 @@ async def test_power_distributor_invalid_battery_id(self) -> None:
         with mock.patch("asyncio.sleep", new_callable=AsyncMock) and mock.patch(
             "frequenz.sdk.microgrid.get", return_value=mock_microgrid
         ):
-
             distributor = PowerDistributingActor(service_channels)
 
             # Mock that all requested batteries are working.
@@ -446,7 +445,6 @@ async def test_power_distributor_overlapping_batteries(self) -> None:
         with mock.patch("asyncio.sleep", new_callable=AsyncMock) and mock.patch(
             "frequenz.sdk.microgrid.get", return_value=mock_microgrid
         ):
-
             distributor = PowerDistributingActor(service_channels)
 
             # Mock that all requested batteries are working.
@@ -545,7 +543,6 @@ async def test_power_distributor_one_user_adjust_power_consume(
         with mock.patch("asyncio.sleep", new_callable=AsyncMock) and mock.patch(
             "frequenz.sdk.microgrid.get", return_value=mock_microgrid
         ):
-
             distributor = PowerDistributingActor(service_channels)
 
             # Mock that all requested batteries are working.
@@ -612,7 +609,6 @@ async def test_power_distributor_one_user_adjust_power_supply(
         with mock.patch("asyncio.sleep", new_callable=AsyncMock) and mock.patch(
             "frequenz.sdk.microgrid.get", return_value=mock_microgrid
         ):
-
             distributor = PowerDistributingActor(service_channels)
 
             # Mock that all requested batteries are working.
@@ -679,7 +675,6 @@ async def test_power_distributor_one_user_adjust_power_success(
         with mock.patch("asyncio.sleep", new_callable=AsyncMock) and mock.patch(
             "frequenz.sdk.microgrid.get", return_value=mock_microgrid
         ):
-
             distributor = PowerDistributingActor(service_channels)
 
             # Mock that all requested batteries are working.
@@ -739,7 +734,6 @@ async def test_not_all_batteries_are_working(
         with mock.patch("asyncio.sleep", new_callable=AsyncMock) and mock.patch(
             "frequenz.sdk.microgrid.get", return_value=mock_microgrid
         ):
-
             distributor = PowerDistributingActor({"user1": channel.service_handle})
 
             # Mock that all requested batteries are working.

tests/data_ingestion/base_microgrid_data_test.py

@@ -129,7 +129,6 @@ async def _collect_microgrid_data(
             metric: [] for metric in metrics
         }
         while await select.ready():
-
             for metric in metrics:
                 if msg := getattr(select, metric):
                     returned_data[metric].append(msg.inner)

tests/microgrid/test_graph.py

@@ -32,7 +32,6 @@ def _check_predecessors_and_successors(graph: gr.ComponentGraph) -> None:
     }
 
     for conn in graph.connections():
-
         if conn.end not in expected_predecessors:
             expected_predecessors[conn.end] = set()
         expected_predecessors[conn.end].add(components[conn.start])