Skip to content

Commit a7cb6ea

Browse files
committed
Improve get_missing_energy_logs()
1 parent ee306ec commit a7cb6ea

File tree

1 file changed

+14
-18
lines changed

1 file changed

+14
-18
lines changed

plugwise_usb/nodes/circle.py

Lines changed: 14 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -429,7 +429,7 @@ async def get_missing_energy_logs(self) -> None:
429429
if self._current_log_address is None:
430430
return None
431431

432-
if self._energy_counters.log_addresses_missing is None:
432+
if (missing_addresses := self._energy_counters.log_addresses_missing) is None:
433433
_LOGGER.debug(
434434
"Start with initial energy request for the last 10 log addresses for node %s.",
435435
self._mac_in_str,
@@ -447,23 +447,19 @@ async def get_missing_energy_logs(self) -> None:
447447
return
448448

449449
_LOGGER.debug("Task created to get missing logs of %s", self._mac_in_str)
450-
if (
451-
missing_addresses := self._energy_counters.log_addresses_missing
452-
) is not None:
453-
_LOGGER.debug(
454-
"Task Request %s missing energy logs for node %s | %s",
455-
str(len(missing_addresses)),
456-
self._mac_in_str,
457-
str(missing_addresses),
458-
)
459-
460-
missing_addresses = sorted(missing_addresses, reverse=True)
461-
tasks = [
462-
create_task(self.energy_log_update(address))
463-
for address in missing_addresses
464-
]
465-
for task in tasks:
466-
await task
450+
_LOGGER.debug(
451+
"Task Request %s missing energy logs for node %s | %s",
452+
str(len(missing_addresses)),
453+
self._mac_in_str,
454+
str(missing_addresses),
455+
)
456+
missing_addresses = sorted(missing_addresses, reverse=True)
457+
tasks = [
458+
create_task(self.energy_log_update(address))
459+
for address in missing_addresses
460+
]
461+
for task in tasks:
462+
await task
467463

468464
if self._cache_enabled:
469465
await self._energy_log_records_save_to_cache()

0 commit comments

Comments
 (0)