File tree Expand file tree Collapse file tree 1 file changed +8
-6
lines changed
Expand file tree Collapse file tree 1 file changed +8
-6
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
66from collections .abc import Awaitable , Callable
77from dataclasses import replace
88from datetime import UTC , datetime
@@ -458,8 +458,7 @@ async def get_missing_energy_logs(self) -> None:
458458
459459 return
460460
461- if self ._energy_counters .log_addresses_missing is not None :
462- _LOGGER .debug ("Task created to get missing logs of %s" , self ._mac_in_str )
461+ _LOGGER .debug ("Task created to get missing logs of %s" , self ._mac_in_str )
463462 if (
464463 missing_addresses := self ._energy_counters .log_addresses_missing
465464 ) is not None :
@@ -471,9 +470,12 @@ async def get_missing_energy_logs(self) -> None:
471470 )
472471
473472 missing_addresses = sorted (missing_addresses , reverse = True )
474- for address in missing_addresses :
475- await sleep (0 )
476- await self .energy_log_update (address )
473+ tasks = [
474+ create_task (self .energy_log_update (address ))
475+ for address in missing_addresses
476+ ]
477+ for task in tasks :
478+ await task
477479
478480 if self ._cache_enabled :
479481 await self ._energy_log_records_save_to_cache ()
You can’t perform that action at this time.
0 commit comments