Skip to content

Commit 03e614c

Browse files
committed
Updates by ruff
1 parent 911d89c commit 03e614c

File tree

1 file changed

+26
-14
lines changed

1 file changed

+26
-14
lines changed

plugwise_usb/nodes/circle.py

Lines changed: 26 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -463,7 +463,10 @@ async def get_missing_energy_logs(self) -> None:
463463
else:
464464
log_interval = self.energy_consumption_interval
465465
_LOGGER.debug("log_interval: %s", log_interval)
466-
_LOGGER.debug("energy_production_interval: %s", self.energy_production_interval)
466+
_LOGGER.debug(
467+
"energy_production_interval: %s",
468+
self.energy_production_interval,
469+
)
467470
factor = 4
468471
if self.energy_production_interval is not None:
469472
factor = 2
@@ -474,10 +477,15 @@ async def get_missing_energy_logs(self) -> None:
474477
and log_interval is not None
475478
and prev_address_timestamp is not None
476479
and (
477-
prev_address_timestamp - self._last_collected_energy_timestamp
478-
).total_seconds() // 60 > (factor * log_interval) + 5 # minutes
480+
prev_address_timestamp
481+
- self._last_collected_energy_timestamp
482+
).total_seconds()
483+
// 60
484+
> (factor * log_interval) + 5 # minutes
479485
):
480-
_LOGGER.debug("Collected energy data is outdated, stopping collection")
486+
_LOGGER.debug(
487+
"Collected energy data is outdated, stopping collection"
488+
)
481489
break
482490

483491
if self._last_collected_energy_timestamp is not None:
@@ -551,14 +559,16 @@ async def energy_log_update(self, address: int | None) -> bool:
551559
):
552560
energy_record_update = True
553561
if not last_energy_timestamp_collected:
554-
self._last_collected_energy_timestamp = (
555-
log_timestamp.replace(tzinfo=UTC)
562+
self._last_collected_energy_timestamp = log_timestamp.replace(
563+
tzinfo=UTC
556564
)
557565
last_energy_timestamp_collected = True
558566

559567
self._energy_counters.update()
560568
if energy_record_update:
561-
_LOGGER.debug("Saving energy record update to cache for %s", self._mac_in_str)
569+
_LOGGER.debug(
570+
"Saving energy record update to cache for %s", self._mac_in_str
571+
)
562572
await self.save_cache()
563573

564574
return True
@@ -639,7 +649,7 @@ async def _energy_log_records_save_to_cache(self) -> None:
639649
cached_logs += f"-{log.timestamp.month}-{log.timestamp.day}"
640650
cached_logs += f"-{log.timestamp.hour}-{log.timestamp.minute}"
641651
cached_logs += f"-{log.timestamp.second}:{log.pulses}"
642-
652+
643653
_LOGGER.debug("Saving energy logrecords to cache for %s", self._mac_in_str)
644654
self._set_cache(CACHE_ENERGY_COLLECTION, cached_logs)
645655

@@ -684,7 +694,7 @@ async def _energy_log_record_update_state(
684694
"Cache is empty, adding new logrecord (%s, %s) for %s",
685695
str(address),
686696
str(slot),
687-
self._mac_in_str
697+
self._mac_in_str,
688698
)
689699
self._set_cache(CACHE_ENERGY_COLLECTION, log_cache_record)
690700
return True
@@ -799,7 +809,9 @@ async def _relay_update_lock(self, state: bool, load_from_cache=False) -> None:
799809
NodeFeature.RELAY_LOCK, self._relay_lock
800810
)
801811
if not load_from_cache:
802-
_LOGGER.debug("Saving relay lock state update to cache for %s", self._mac_in_str)
812+
_LOGGER.debug(
813+
"Saving relay lock state update to cache for %s", self._mac_in_str
814+
)
803815
await self.save_cache()
804816

805817
async def clock_synchronize(self) -> bool:
@@ -1135,7 +1147,9 @@ async def _relay_init_update_state(self, state: bool) -> None:
11351147
await self.publish_feature_update_to_subscribers(
11361148
NodeFeature.RELAY_INIT, self._relay_config
11371149
)
1138-
_LOGGER.debug("Saving relay_init state update to cachefor %s", self._mac_in_str)
1150+
_LOGGER.debug(
1151+
"Saving relay_init state update to cachefor %s", self._mac_in_str
1152+
)
11391153
await self.save_cache()
11401154

11411155
@raise_calibration_missing
@@ -1246,9 +1260,7 @@ async def get_state(self, features: tuple[NodeFeature]) -> dict[NodeFeature, Any
12461260
async def energy_reset_request(self) -> None:
12471261
"""Send an energy-reset to a Node."""
12481262
if self._node_protocols is None:
1249-
raise NodeError(
1250-
"Unable to energy-reset when protocol version is unknown"
1251-
)
1263+
raise NodeError("Unable to energy-reset when protocol version is unknown")
12521264

12531265
request = CircleClockSetRequest(
12541266
self._send,

0 commit comments

Comments
 (0)