Introduce a delay between restarts of ComponentPoolStatusTracker

shsms · shsms · commit 0df76fcc793f · 2023-11-20T12:27:09.000+01:00
This is never expected to happen, because the task only reads from
channels and writes to channels, and unless there's a bug in the SDK
that closes the channels, the task won't die.

Signed-off-by: Sahas Subramanian &lt;sahas.subramanian@proton.me&gt;
diff --git a/src/frequenz/sdk/actor/power_distributing/_component_pool_status_tracker.py b/src/frequenz/sdk/actor/power_distributing/_component_pool_status_tracker.py
@@ -117,6 +117,7 @@ async def _run(self) -> None:
                 _logger.error(
                     "ComponentPoolStatus failed with error: %s. Restarting.", err
                 )
+                await asyncio.sleep(1.0)
 
     async def _update_status(self) -> None:
         async for status in self._merged_status_receiver:

Original file line number	Diff line number	Diff line change
`@@ -117,6 +117,7 @@ async def _run(self) -> None:`
`117`	`117`	`_logger.error(`
`118`	`118`	`"ComponentPoolStatus failed with error: %s. Restarting.", err`
`119`	`119`	`)`
	`120`	`+ await asyncio.sleep(1.0)`
`120`	`121`
`121`	`122`	`async def _update_status(self) -> None:`
`122`	`123`	`async for status in self._merged_status_receiver:`