Skip to content

Commit 0164d54

Browse files
committed
Add missing timezone
1 parent b716df6 commit 0164d54

File tree

3 files changed

+6
-6
lines changed

3 files changed

+6
-6
lines changed

plugwise_usb/messages/__init__.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ def __init__(self) -> None:
3131
self._args: list[Any] = []
3232
self._seq_id: bytes | None = None
3333
self.priority: Priority = Priority.MEDIUM
34-
self.timestamp = datetime.now(UTC)
34+
self.timestamp = datetime.now(tz=UTC)
3535

3636
@property
3737
def seq_id(self) -> bytes | None:

plugwise_usb/nodes/circle.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -279,7 +279,7 @@ async def energy_update(self) -> EnergyStatistics | None:
279279
if await self.node_info_update() is None:
280280
if (
281281
self._initialization_delay_expired is not None
282-
and datetime.now(UTC) < self._initialization_delay_expired
282+
and datetime.now(tz=UTC) < self._initialization_delay_expired
283283
):
284284
_LOGGER.info(
285285
"Unable to return energy statistics for %s, because it is not responding",
@@ -369,7 +369,7 @@ async def energy_update(self) -> EnergyStatistics | None:
369369
)
370370
if (
371371
self._initialization_delay_expired is not None
372-
and datetime.now(UTC) < self._initialization_delay_expired
372+
and datetime.now(tz=UTC) < self._initialization_delay_expired
373373
):
374374
_LOGGER.info(
375375
"Unable to return energy statistics for %s, collecting required data...",

plugwise_usb/nodes/helpers/pulses.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -109,7 +109,7 @@ def logs(self) -> dict[int, dict[int, PulseLogRecord]]:
109109
if self._logs is None:
110110
return {}
111111
sorted_log: dict[int, dict[int, PulseLogRecord]] = {}
112-
skip_before = datetime.now(UTC) - timedelta(hours=MAX_LOG_HOURS)
112+
skip_before = datetime.now(tz=UTC) - timedelta(hours=MAX_LOG_HOURS)
113113
sorted_addresses = sorted(self._logs.keys(), reverse=True)
114114
for address in sorted_addresses:
115115
sorted_slots = sorted(self._logs[address].keys(), reverse=True)
@@ -389,7 +389,7 @@ def add_log(
389389
def recalculate_missing_log_addresses(self) -> None:
390390
"""Recalculate missing log addresses."""
391391
self._log_addresses_missing = self._logs_missing(
392-
datetime.now(UTC) - timedelta(hours=MAX_LOG_HOURS)
392+
datetime.now(tz=UTC) - timedelta(hours=MAX_LOG_HOURS)
393393
)
394394

395395
def _add_log_record(
@@ -406,7 +406,7 @@ def _add_log_record(
406406
return False
407407
# Drop useless log records when we have at least 4 logs
408408
if self.collected_logs > 4 and log_record.timestamp < (
409-
datetime.now(UTC) - timedelta(hours=MAX_LOG_HOURS)
409+
datetime.now(tz=UTC) - timedelta(hours=MAX_LOG_HOURS)
410410
):
411411
return False
412412
if self._logs.get(address) is None:

0 commit comments

Comments
 (0)