Give more receivers/tasks a name for easier debugging

Signed-off-by: Mathias L. Baumann <[email protected]>

Author: Marenz

src/frequenz/sdk/microgrid/_data_pipeline.py

@@ -454,7 +454,9 @@ def _data_sourcing_request_sender(self) -> Sender[ComponentMetricRequest]:
                 name="Data Pipeline: Data Sourcing Actor Request Channel"
             )
             actor = DataSourcingActor(
-                request_receiver=channel.new_receiver(limit=_REQUEST_RECV_BUFFER_SIZE),
+                request_receiver=channel.new_receiver(
+                    limit=_REQUEST_RECV_BUFFER_SIZE, name=channel.name + " Receiver"
+                ),
                 registry=self._channel_registry,
             )
             self._data_sourcing_actor = _ActorInfo(actor, channel)
@@ -479,7 +481,8 @@ def _resampling_request_sender(self) -> Sender[ComponentMetricRequest]:
                 channel_registry=self._channel_registry,
                 data_sourcing_request_sender=self._data_sourcing_request_sender(),
                 resampling_request_receiver=channel.new_receiver(
-                    limit=_REQUEST_RECV_BUFFER_SIZE
+                    limit=_REQUEST_RECV_BUFFER_SIZE,
+                    name=channel.name + " Receiver",
                 ),
                 config=self._resampler_config,
             )

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

@@ -461,7 +461,8 @@ async def _update_streams(
             self.comp_data_tasks[comp_id].cancel()
 
         self.comp_data_tasks[comp_id] = asyncio.create_task(
-            run_forever(lambda: self._handle_data_stream(comp_id, category))
+            run_forever(lambda: self._handle_data_stream(comp_id, category)),
+            name=f"run_forever:cid={comp_id}",
         )
 
     async def add_metric(self, request: ComponentMetricRequest) -> None: