Specify name as a kw argument when creating channels and receivers

This parameter has become a keyword argument with channel v1.0.0-rc1.

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

Author: shsms

benchmarks/power_distribution/power_distributor.py

@@ -111,9 +111,9 @@ async def run_test(  # pylint: disable=too-many-locals
     """
     start = timeit.default_timer()
 
-    power_request_channel = Broadcast[Request]("power-request")
-    battery_status_channel = Broadcast[ComponentPoolStatus]("battery-status")
-    power_result_channel = Broadcast[Result]("power-result")
+    power_request_channel = Broadcast[Request](name="power-request")
+    battery_status_channel = Broadcast[ComponentPoolStatus](name="battery-status")
+    power_result_channel = Broadcast[Result](name="power-result")
     async with PowerDistributingActor(
         requests_receiver=power_request_channel.new_receiver(),
         results_sender=power_result_channel.new_sender(),

benchmarks/timeseries/benchmark_datasourcing.py

@@ -77,12 +77,13 @@ async def benchmark_data_sourcing(
     mock_grid.start_mock_client(enable_mock_client)
 
     request_channel = Broadcast[ComponentMetricRequest](
-        "DataSourcingActor Request Channel"
+        name="DataSourcingActor Request Channel"
     )
 
     channel_registry = ChannelRegistry(name="Microgrid Channel Registry")
     request_receiver = request_channel.new_receiver(
-        "datasourcing-benchmark", maxsize=(num_ev_chargers * len(COMPONENT_METRIC_IDS))
+        name="datasourcing-benchmark",
+        maxsize=(num_ev_chargers * len(COMPONENT_METRIC_IDS)),
     )
     request_sender = request_channel.new_sender()
 

benchmarks/timeseries/periodic_feature_extractor.py

@@ -33,7 +33,7 @@ async def init_feature_extractor(
 ) -> collections.abc.AsyncIterator[PeriodicFeatureExtractor]:
     """Initialize the PeriodicFeatureExtractor class."""
     # We only need the moving window to initialize the PeriodicFeatureExtractor class.
-    lm_chan = Broadcast[Sample[Quantity]]("lm_net_power")
+    lm_chan = Broadcast[Sample[Quantity]](name="lm_net_power")
     async with MovingWindow(
         timedelta(seconds=1), lm_chan.new_receiver(), timedelta(seconds=1)
     ) as moving_window:

src/frequenz/sdk/actor/_channel_registry.py

@@ -98,7 +98,9 @@ def get_or_create(self, message_type: type[_T], key: str) -> Broadcast[_T]:
                     message_type,
                     "".join(traceback.format_stack(limit=10)[:9]),
                 )
-            self._channels[key] = _Entry(message_type, Broadcast(f"{self._name}-{key}"))
+            self._channels[key] = _Entry(
+                message_type, Broadcast(name=f"{self._name}-{key}")
+            )
 
         entry = self._channels[key]
         if entry.message_type is not message_type:

src/frequenz/sdk/actor/power_distributing/_component_pool_status_tracker.py

@@ -65,7 +65,7 @@ def __init__(  # pylint: disable=too-many-arguments
 
         # Channel for sending results of requests to the components.
         self._set_power_result_channel = Broadcast[SetPowerResult](
-            "component_request_status"
+            name="component_request_status"
         )
         self._set_power_result_sender = self._set_power_result_channel.new_sender()
         self._component_status_trackers: list[ComponentStatusTracker] = []
@@ -92,7 +92,7 @@ def _make_merged_status_receiver(
 
         for component_id in self._component_ids:
             channel: Broadcast[ComponentStatus] = Broadcast(
-                f"component_{component_id}_status"
+                name=f"component_{component_id}_status"
             )
             tracker = self._component_status_tracker_type(
                 component_id=component_id,

src/frequenz/sdk/microgrid/_data_pipeline.py

@@ -259,7 +259,7 @@ def _data_sourcing_request_sender(self) -> Sender[ComponentMetricRequest]:
 
         if self._data_sourcing_actor is None:
             channel: Broadcast[ComponentMetricRequest] = Broadcast(
-                "Data Pipeline: Data Sourcing Actor Request Channel"
+                name="Data Pipeline: Data Sourcing Actor Request Channel"
             )
             actor = DataSourcingActor(
                 request_receiver=channel.new_receiver(
@@ -283,7 +283,7 @@ def _resampling_request_sender(self) -> Sender[ComponentMetricRequest]:
 
         if self._resampling_actor is None:
             channel: Broadcast[ComponentMetricRequest] = Broadcast(
-                "Data Pipeline: Component Metric Resampling Actor Request Channel"
+                name="Data Pipeline: Component Metric Resampling Actor Request Channel"
             )
             actor = ComponentMetricsResamplingActor(
                 channel_registry=self._channel_registry,

src/frequenz/sdk/microgrid/_power_wrapper.py

@@ -43,20 +43,20 @@ def __init__(self, channel_registry: ChannelRegistry):
         self._channel_registry = channel_registry
 
         self.status_channel: Broadcast[ComponentPoolStatus] = Broadcast(
-            "Component Status Channel", resend_latest=True
+            name="Component Status Channel", resend_latest=True
         )
         self._power_distribution_requests_channel: Broadcast[Request] = Broadcast(
-            "Power Distributing Actor, Requests Broadcast Channel"
+            name="Power Distributing Actor, Requests Broadcast Channel"
         )
         self._power_distribution_results_channel: Broadcast[Result] = Broadcast(
-            "Power Distributing Actor, Results Broadcast Channel"
+            name="Power Distributing Actor, Results Broadcast Channel"
         )
 
         self.proposal_channel: Broadcast[_power_managing.Proposal] = Broadcast(
-            "Power Managing Actor, Requests Broadcast Channel"
+            name="Power Managing Actor, Requests Broadcast Channel"
         )
         self.bounds_subscription_channel: Broadcast[_power_managing.ReportRequest] = (
-            Broadcast("Power Managing Actor, Bounds Subscription Channel")
+            Broadcast(name="Power Managing Actor, Bounds Subscription Channel")
         )
 
         self._power_distributing_actor: PowerDistributingActor | None = None

src/frequenz/sdk/timeseries/_moving_window.py

@@ -65,7 +65,7 @@ async def send_mock_data(sender: Sender[Sample]) -> None:
                 await asyncio.sleep(1.0)
 
         async def run() -> None:
-            resampled_data_channel = Broadcast[Sample]("sample-data")
+            resampled_data_channel = Broadcast[Sample](name="sample-data")
             resampled_data_receiver = resampled_data_channel.new_receiver()
             resampled_data_sender = resampled_data_channel.new_sender()
 
@@ -102,7 +102,7 @@ async def send_mock_data(sender: Sender[Sample]) -> None:
                 await asyncio.sleep(1.0)
 
         async def run() -> None:
-            resampled_data_channel = Broadcast[Sample]("sample-data")
+            resampled_data_channel = Broadcast[Sample](name="sample-data")
             resampled_data_receiver = resampled_data_channel.new_receiver()
             resampled_data_sender = resampled_data_channel.new_sender()
 
@@ -345,7 +345,7 @@ async def sink_buffer(sample: Sample[Quantity]) -> None:
             if sample.value is not None:
                 self._buffer.update(sample)
 
-        resampler_channel = Broadcast[Sample[Quantity]]("average")
+        resampler_channel = Broadcast[Sample[Quantity]](name="average")
         self._resampler_sender = resampler_channel.new_sender()
         self._resampler.add_timeseries(
             "avg", resampler_channel.new_receiver(), sink_buffer

src/frequenz/sdk/timeseries/ev_charger_pool/_ev_charger_pool.py

@@ -202,7 +202,7 @@ def component_data(self, component_id: int) -> Receiver[EVChargerData]:
             _logger.warning("Restarting component_status for id: %s", component_id)
         else:
             output_chan = Broadcast[EVChargerData](
-                f"evpool-component_status-{component_id}"
+                name=f"evpool-component_status-{component_id}"
             )
 
         task = asyncio.create_task(

src/frequenz/sdk/timeseries/ev_charger_pool/_set_current_bounds.py

@@ -50,7 +50,9 @@ def __init__(self, repeat_interval: timedelta) -> None:
         self._repeat_interval = repeat_interval
 
         self._task: asyncio.Task[None] = asyncio.create_task(self._run())
-        self._bounds_chan: Broadcast[ComponentCurrentLimit] = Broadcast("BoundsSetter")
+        self._bounds_chan: Broadcast[ComponentCurrentLimit] = Broadcast(
+            name="BoundsSetter"
+        )
         self._bounds_rx = self._bounds_chan.new_receiver()
         self._bounds_tx = self._bounds_chan.new_sender()