Apply formattnig

Author: brefra

plugwise_usb/messages/requests.py

@@ -750,7 +750,7 @@ class CircleClockSetRequest(PlugwiseRequest):
     _identifier = b"0016"
     _reply_identifier = b"0000"
 
-    def __init__( # pylint: disable=too-many-arguments
+    def __init__(  # pylint: disable=too-many-arguments
         self,
         send_fn: Callable[[PlugwiseRequest, bool], Awaitable[PlugwiseResponse | None]],
         mac: bytes,
@@ -1083,7 +1083,7 @@ class NodeAddToGroupRequest(PlugwiseRequest):
     _identifier = b"0045"
     _reply_identifier = b"0000"
 
-    def __init__( # pylint: disable=too-many-arguments
+    def __init__(  # pylint: disable=too-many-arguments
         self,
         send_fn: Callable[[PlugwiseRequest, bool], Awaitable[PlugwiseResponse | None]],
         mac: bytes,
@@ -1231,7 +1231,7 @@ class NodeSleepConfigRequest(PlugwiseRequest):
     _identifier = b"0050"
     _reply_identifier = b"0000"
 
-    def __init__( # pylint: disable=too-many-arguments
+    def __init__(  # pylint: disable=too-many-arguments
         self,
         send_fn: Callable[[PlugwiseRequest, bool], Awaitable[PlugwiseResponse | None]],
         mac: bytes,
@@ -1402,7 +1402,7 @@ class ScanConfigureRequest(PlugwiseRequest):
     _identifier = b"0101"
     _reply_identifier = b"0100"
 
-    def __init__( # pylint: disable=too-many-arguments
+    def __init__(  # pylint: disable=too-many-arguments
         self,
         send_fn: Callable[[PlugwiseRequest, bool], Awaitable[PlugwiseResponse | None]],
         mac: bytes,

plugwise_usb/nodes/circle.py

@@ -911,7 +911,7 @@ async def _node_info_load_from_cache(self) -> bool:
             return result
         return False
 
-    async def update_node_details( # pylint: disable=too-many-arguments
+    async def update_node_details(  # pylint: disable=too-many-arguments
         self,
         firmware: datetime | None,
         hardware: str | None,

plugwise_usb/nodes/helpers/counter.py

@@ -1,4 +1,5 @@
 """Energy counter."""
+
 from __future__ import annotations
 
 from datetime import datetime, timedelta
@@ -81,21 +82,17 @@ def add_empty_log(self, address: int, slot: int) -> None:
         """Add empty energy log record to mark any start of beginning of energy log collection."""
         self._pulse_collection.add_empty_log(address, slot)
 
-    def add_pulse_log(
+    def add_pulse_log(  # pylint: disable=too-many-arguments
         self,
         address: int,
         slot: int,
         timestamp: datetime,
         pulses: int,
-        import_only: bool = False
-    ) -> None: # pylint: disable=too-many-arguments
+        import_only: bool = False,
+    ) -> None:
         """Add pulse log."""
         if self._pulse_collection.add_log(
-            address,
-            slot,
-            timestamp,
-            pulses,
-            import_only
+            address, slot, timestamp, pulses, import_only
         ):
             if not import_only:
                 self.update()
@@ -160,45 +157,37 @@ def update(self) -> None:
         self._pulse_collection.recalculate_missing_log_addresses()
         if self._calibration is None:
             return
-        self._energy_statistics.log_interval_consumption = self._pulse_collection.log_interval_consumption
-        self._energy_statistics.log_interval_production = self._pulse_collection.log_interval_production
+        self._energy_statistics.log_interval_consumption = (
+            self._pulse_collection.log_interval_consumption
+        )
+        self._energy_statistics.log_interval_production = (
+            self._pulse_collection.log_interval_production
+        )
         (
             self._energy_statistics.hour_consumption,
             self._energy_statistics.hour_consumption_reset,
-        ) = self._counters[EnergyType.CONSUMPTION_HOUR].update(
-            self._pulse_collection
-        )
+        ) = self._counters[EnergyType.CONSUMPTION_HOUR].update(self._pulse_collection)
         (
             self._energy_statistics.day_consumption,
             self._energy_statistics.day_consumption_reset,
-        ) = self._counters[EnergyType.CONSUMPTION_DAY].update(
-            self._pulse_collection
-        )
+        ) = self._counters[EnergyType.CONSUMPTION_DAY].update(self._pulse_collection)
         (
             self._energy_statistics.week_consumption,
             self._energy_statistics.week_consumption_reset,
-        ) = self._counters[EnergyType.CONSUMPTION_WEEK].update(
-            self._pulse_collection
-        )
+        ) = self._counters[EnergyType.CONSUMPTION_WEEK].update(self._pulse_collection)
 
         (
             self._energy_statistics.hour_production,
             self._energy_statistics.hour_production_reset,
-        ) = self._counters[EnergyType.PRODUCTION_HOUR].update(
-            self._pulse_collection
-        )
+        ) = self._counters[EnergyType.PRODUCTION_HOUR].update(self._pulse_collection)
         (
             self._energy_statistics.day_production,
             self._energy_statistics.day_production_reset,
-        ) = self._counters[EnergyType.PRODUCTION_DAY].update(
-            self._pulse_collection
-        )
+        ) = self._counters[EnergyType.PRODUCTION_DAY].update(self._pulse_collection)
         (
             self._energy_statistics.week_production,
             self._energy_statistics.week_production_reset,
-        ) = self._counters[EnergyType.PRODUCTION_WEEK].update(
-            self._pulse_collection
-        )
+        ) = self._counters[EnergyType.PRODUCTION_WEEK].update(self._pulse_collection)
 
     @property
     def timestamp(self) -> datetime | None:
@@ -223,9 +212,7 @@ def __init__(
         """Initialize energy counter based on energy id."""
         self._mac = mac
         if energy_id not in ENERGY_COUNTERS:
-            raise EnergyError(
-                f"Invalid energy id '{energy_id}' for Energy counter"
-            )
+            raise EnergyError(f"Invalid energy id '{energy_id}' for Energy counter")
         self._calibration: EnergyCalibration | None = None
         self._duration = "hour"
         if energy_id in ENERGY_DAY_COUNTERS:
@@ -311,9 +298,7 @@ def update(
         if self._energy_id in ENERGY_HOUR_COUNTERS:
             last_reset = last_reset.replace(minute=0, second=0, microsecond=0)
         elif self._energy_id in ENERGY_DAY_COUNTERS:
-            last_reset = last_reset.replace(
-                hour=0, minute=0, second=0, microsecond=0
-            )
+            last_reset = last_reset.replace(hour=0, minute=0, second=0, microsecond=0)
         elif self._energy_id in ENERGY_WEEK_COUNTERS:
             last_reset = last_reset - timedelta(days=last_reset.weekday())
             last_reset = last_reset.replace(

plugwise_usb/nodes/helpers/pulses.py

@@ -363,14 +363,14 @@ def add_empty_log(self, address: int, slot: int) -> None:
         if recalculate:
             self.recalculate_missing_log_addresses()
 
-    def add_log(
+    def add_log(  # pylint: disable=too-many-arguments
         self,
         address: int,
         slot: int,
         timestamp: datetime,
         pulses: int,
         import_only: bool = False,
-    ) -> bool: # pylint: disable=too-many-arguments
+    ) -> bool:
         """Store pulse log."""
         log_record = PulseLogRecord(timestamp, pulses, CONSUMED)
         if not self._add_log_record(address, slot, log_record):

plugwise_usb/nodes/node.py

@@ -433,7 +433,9 @@ async def _available_update_state(
             return
         _LOGGER.info("Device %s detected to be not available (off-line)", self.name)
         self._available = False
-        await self.publish_feature_update_to_subscribers(NodeFeature.AVAILABLE, self.available_state)
+        await self.publish_feature_update_to_subscribers(
+            NodeFeature.AVAILABLE, self.available_state
+        )
 
     async def node_info_update(
         self, node_info: NodeInfoResponse | None = None
@@ -474,7 +476,7 @@ async def _node_info_load_from_cache(self) -> bool:
             logaddress_pointer=None,
         )
 
-    async def update_node_details(
+    async def update_node_details(  # pylint: disable=too-many-arguments
         self,
         firmware: datetime | None,
         hardware: str | None,

plugwise_usb/nodes/sed.py

@@ -657,7 +657,7 @@ async def schedule_task_when_awake(
         self._send_task_queue.append(task_fn)
         self._send_task_lock.release()
 
-    async def sed_configure( # pylint: disable=too-many-arguments
+    async def sed_configure(  # pylint: disable=too-many-arguments
         self,
         awake_duration: int,
         sleep_duration: int,
@@ -712,7 +712,7 @@ async def sed_configure( # pylint: disable=too-many-arguments
         )
         return False
 
-    async def _sed_configure_update( # pylint: disable=too-many-arguments
+    async def _sed_configure_update(  # pylint: disable=too-many-arguments
         self,
         awake_duration: int = SED_DEFAULT_AWAKE_DURATION,
         clock_interval: int = SED_DEFAULT_CLOCK_INTERVAL,