Stop fetchers when stopping SendOnUpdate

shsms · shsms · commit 36540799f994 · 2025-01-23T14:56:14.000+01:00
Signed-off-by: Sahas Subramanian &lt;sahas.subramanian@proton.me&gt;
diff --git a/src/frequenz/sdk/timeseries/battery_pool/_methods.py b/src/frequenz/sdk/timeseries/battery_pool/_methods.py
@@ -168,6 +168,8 @@ async def stop(self) -> None:
         await asyncio.gather(
             *[cancel_and_await(self._send_task), cancel_and_await(self._update_task)]
         )
+        for fetcher in self._fetchers.values():
+            fetcher.stop()
 
     async def _create_data_fetchers(self) -> None:
         fetchers: dict[int, ComponentMetricFetcher] = {

Original file line number	Diff line number	Diff line change
`@@ -168,6 +168,8 @@ async def stop(self) -> None:`
`168`	`168`	`await asyncio.gather(`
`169`	`169`	`*[cancel_and_await(self._send_task), cancel_and_await(self._update_task)]`
`170`	`170`	`)`
	`171`	`+ for fetcher in self._fetchers.values():`
	`172`	`+ fetcher.stop()`
`171`	`173`
`172`	`174`	`async def _create_data_fetchers(self) -> None:`
`173`	`175`	`fetchers: dict[int, ComponentMetricFetcher] = {`