Skip to content

Commit 72db8cc

Browse files
committed
Implement gather() for 2nd energy_log_update use
1 parent 117adcc commit 72db8cc

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

plugwise_usb/nodes/circle.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -474,8 +474,11 @@ async def get_missing_energy_logs(self) -> None:
474474
)
475475

476476
missing_addresses = sorted(missing_addresses, reverse=True)
477+
log_update_tasks = []
477478
for address in missing_addresses:
478-
await self.energy_log_update(address)
479+
log_update_tasks.append(self.energy_log_update(address))
480+
481+
await gather(*log_update_tasks)
479482

480483
if self._cache_enabled:
481484
await self._energy_log_records_save_to_cache()

0 commit comments

Comments
 (0)