File tree Expand file tree Collapse file tree 1 file changed +5
-4
lines changed
Expand file tree Collapse file tree 1 file changed +5
-4
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
5+ from asyncio import Task , create_task , gather
66from collections .abc import Awaitable , Callable
77from dataclasses import replace
8+ from math import floor
89from datetime import UTC , datetime
910from functools import wraps
1011import logging
@@ -446,7 +447,8 @@ async def get_missing_energy_logs(self) -> None:
446447 "Start with initial energy request for the last 10 log addresses for node %s." ,
447448 self ._mac_in_str ,
448449 )
449- total_addresses = 11
450+
451+ total_addresses = int (floor (datetime .now (tz = UTC ).hour / 4 ) + 1 )
450452 log_address = self ._current_log_address
451453 while total_addresses > 0 :
452454 await self .energy_log_update (log_address )
@@ -474,8 +476,7 @@ async def get_missing_energy_logs(self) -> None:
474476 create_task (self .energy_log_update (address ))
475477 for address in missing_addresses
476478 ]
477- for task in tasks :
478- await task
479+ await gather (* tasks , return_exceptions = True )
479480
480481 if self ._cache_enabled :
481482 await self ._energy_log_records_save_to_cache ()
You can’t perform that action at this time.
0 commit comments