File tree Expand file tree Collapse file tree 1 file changed +3
-9
lines changed
Expand file tree Collapse file tree 1 file changed +3
-9
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 , gather
5+ from asyncio import Task , create_task
66from collections .abc import Awaitable , Callable
77from dataclasses import replace
88from datetime import UTC , datetime
@@ -449,13 +449,10 @@ async def get_missing_energy_logs(self) -> None:
449449 total_addresses = 11
450450 log_address = self ._current_log_address
451451 while total_addresses > 0 :
452- task = create_task (self .energy_log_update (log_address ))
453- await task
452+ await self .energy_log_update (log_address )
454453 log_address , _ = calc_log_address (log_address , 1 , - 4 )
455454 total_addresses -= 1
456455
457- await gather (* task )
458-
459456 if self ._cache_enabled :
460457 await self ._energy_log_records_save_to_cache ()
461458
@@ -475,10 +472,7 @@ async def get_missing_energy_logs(self) -> None:
475472
476473 missing_addresses = sorted (missing_addresses , reverse = True )
477474 for address in missing_addresses :
478- task = create_task (self .energy_log_update (address ))
479- await task
480-
481- gather (* task )
475+ await self .energy_log_update (address )
482476
483477 if self ._cache_enabled :
484478 await self ._energy_log_records_save_to_cache ()
You can’t perform that action at this time.
0 commit comments