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

Marenz · llucax · web-flow · commit 7f398347c629 · 2024-11-27T12:33:58.000+01:00
Co-authored-by: Leandro Lucarella &lt;luca-frequenz@llucax.com&gt;
Signed-off-by: Mathias L. Baumann &lt;Marenz@users.noreply.github.com&gt;
diff --git a/src/frequenz/sdk/microgrid/_data_sourcing/microgrid_api_source.py b/src/frequenz/sdk/microgrid/_data_sourcing/microgrid_api_source.py
@@ -462,7 +462,7 @@ async def _update_streams(
 
         self.comp_data_tasks[comp_id] = asyncio.create_task(
             run_forever(lambda: self._handle_data_stream(comp_id, category)),
-            name=f"run_forever:cid={comp_id}",
+            name=f"{type(self).__name__}._update_stream({comp_id=}, {category.name})",
         )
 
     async def add_metric(self, request: ComponentMetricRequest) -> None:

Original file line number	Diff line number	Diff line change
`@@ -462,7 +462,7 @@ async def _update_streams(`
`462`	`462`
`463`	`463`	`self.comp_data_tasks[comp_id] = asyncio.create_task(`
`464`	`464`	`run_forever(lambda: self._handle_data_stream(comp_id, category)),`
`465`		`- name=f"run_forever:cid={comp_id}",`
	`465`	`+ name=f"{type(self).__name__}._update_stream({comp_id=}, {category.name})",`
`466`	`466`	`)`
`467`	`467`
`468`	`468`	`async def add_metric(self, request: ComponentMetricRequest) -> None:`