jeans/core
jeans/core
1
0
Fork 0
mirror of https://github.com/home-assistant/core.git synced 2025-04-25 17:57:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

mill

Browse Source 
Signed-off-by: Daniel Hjelseth Høyer <github@dahoiv.net>
This commit is contained in:
Daniel Hjelseth Høyer 2025-03-17 21:22:37 +01:00
parent 54c36a33f4
commit a6f508c624
2 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
homeassistant/components/mill/coordinator.py
View File

@ -79,12 +79,13 @@ class MillHistoricDataUpdateCoordinator(DataUpdateCoordinator):
timedelta(hours=1) + now.replace(minute=0, second=0) - now timedelta(hours=1) + now.replace(minute=0, second=0) - now
) )
recoder_instance = get_instance(self.hass)
for dev_id, heater in self.mill_data_connection.devices.items(): for dev_id, heater in self.mill_data_connection.devices.items():
if not isinstance(heater, Heater): if not isinstance(heater, Heater):
continue continue
statistic_id = f"{DOMAIN}:energy_{slugify(dev_id)}" statistic_id = f"{DOMAIN}:energy_{slugify(dev_id)}"
last_stats = await get_instance(self.hass).async_add_executor_job( last_stats = await recoder_instance.async_add_executor_job(
get_last_statistics, self.hass, 1, statistic_id, True, set() get_last_statistics, self.hass, 1, statistic_id, True, set()
) )
@ -115,7 +116,7 @@ class MillHistoricDataUpdateCoordinator(DataUpdateCoordinator):
hourly_data = dict(sorted(hourly_data.items(), key=lambda x: x[0])) hourly_data = dict(sorted(hourly_data.items(), key=lambda x: x[0]))
start_time = next(iter(hourly_data)) start_time = next(iter(hourly_data))
stats = await get_instance(self.hass).async_add_executor_job( stats = await recoder_instance.async_add_executor_job(
statistics_during_period, statistics_during_period,
self.hass, self.hass,
start_time, start_time,

0
tests/components/mill/test_statistics.py → tests/components/mill/test_coordinator.py
View File