Update code to pass newly-released black v23.1.0

Signed-off-by: Sahas Subramanian <[email protected]>

Author: shsms

examples/resampling.py

@@ -110,6 +110,7 @@ async def run() -> None:  # pylint: disable=too-many-locals
     )
 
     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_battery_status.py

@@ -213,6 +213,7 @@ def __init__(
 BATTERY_ID = 106
 INVERTER_ID = 105
 
+
 # pylint: disable=protected-access, unused-argument
 class TestBatteryStatus:
     """Tests BatteryStatusTracker."""

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])

tests/timeseries/test_ringbuffer.py

@@ -201,7 +201,6 @@ def test_timestamp_ringbuffer_missing_parameter_smoke(
     random.seed(0)
 
     for _ in range(0, 10):
-
         expected_gaps_abstract = [(0.1, 0.2), (0.35, 0.4), (0.86, 1.0)]
         expected_gaps_concrete = list(
             map(lambda x: (int(size * x[0]), int(size * x[1])), expected_gaps_abstract)