File tree Expand file tree Collapse file tree 1 file changed +5
-3
lines changed
Expand file tree Collapse file tree 1 file changed +5
-3
lines changed Original file line number Diff line number Diff line change 22
33from __future__ import annotations
44
5- from asyncio import Task , create_task , sleep
5+ from asyncio import Task , create_task , wait_for
66from collections .abc import Awaitable , Callable
77from dataclasses import replace
88from datetime import UTC , datetime
@@ -473,8 +473,10 @@ async def get_missing_energy_logs(self) -> None:
473473
474474 missing_addresses = sorted (missing_addresses , reverse = True )
475475 for address in missing_addresses :
476- await self .energy_log_update (address )
477- await sleep (0.1 ) # Test with a small delay
476+ try :
477+ await wait_for (self .energy_log_update (address ), timeout = 5.0 )
478+ except TimeoutError :
479+ _LOGGER .error ("Failed to update energy log from %s" , address )
478480
479481 if self ._cache_enabled :
480482 await self ._energy_log_records_save_to_cache ()
You can’t perform that action at this time.
0 commit comments