Skip to content

Commit 2fc2b2f

Browse files
committed
Try to not block the event_loop
1 parent 14e6f57 commit 2fc2b2f

File tree

1 file changed

+8
-2
lines changed

1 file changed

+8
-2
lines changed

plugwise_usb/nodes/circle.py

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -449,10 +449,13 @@ 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-
await self.energy_log_update(log_address)
452+
task = create_task(self.energy_log_update(log_address))
453+
await task
453454
log_address, _ = calc_log_address(log_address, 1, -4)
454455
total_addresses -= 1
455456

457+
await gather(*task)
458+
456459
if self._cache_enabled:
457460
await self._energy_log_records_save_to_cache()
458461

@@ -472,7 +475,10 @@ async def get_missing_energy_logs(self) -> None:
472475

473476
missing_addresses = sorted(missing_addresses, reverse=True)
474477
for address in missing_addresses:
475-
await self.energy_log_update(address)
478+
task = create_task(self.energy_log_update(address))
479+
await task
480+
481+
gather(*task)
476482

477483
if self._cache_enabled:
478484
await self._energy_log_records_save_to_cache()

0 commit comments

Comments
 (0)