jpawlowski/hass.tibber_prices
1
0
Fork 0
mirror of https://github.com/jpawlowski/hass.tibber_prices.git synced 2026-03-30 05:13:40 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 2

fix

Browse source
This commit is contained in:
Julian Pawlowski 2025-11-03 22:26:51 +00:00
parent c3b3cf82bd
commit f7991ae71c
1 changed files with 19 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

23
custom_components/tibber_prices/coordinator.py
View file

@ -123,13 +123,16 @@ class TibberPricesDataUpdateCoordinator(DataUpdateCoordinator[dict[str, Any]]):
minutes_to_wait, minutes_to_wait,
) )
@callback
def _handle_quarter_hour_refresh(self) -> None: def _handle_quarter_hour_refresh(self) -> None:
"""Handle quarter-hour entity refresh by triggering async state updates.""" """Handle quarter-hour entity refresh by triggering async state updates."""
_LOGGER.debug("Quarter-hour refresh triggered at %s", dt_util.utcnow().isoformat()) _LOGGER.debug("Quarter-hour refresh triggered at %s", dt_util.utcnow().isoformat())
# Notify all listeners that there's new data without fetching fresh data # Notify all listeners to update their state without fetching fresh data
# This causes entity state properties to be re-evaluated with the current time # This causes entity state properties to be re-evaluated with the current time
self.async_set_updated_data(self.data) # Using async_update_listeners() instead of async_set_updated_data() to avoid
# interfering with the coordinator's update timing
self.async_update_listeners()
# Schedule the next quarter-hour refresh # Schedule the next quarter-hour refresh
self._schedule_quarter_hour_refresh() self._schedule_quarter_hour_refresh()
@ -390,11 +393,23 @@ class TibberPricesDataUpdateCoordinator(DataUpdateCoordinator[dict[str, Any]]):
def _should_update_price_data(self, current_time: datetime) -> bool: def _should_update_price_data(self, current_time: datetime) -> bool:
"""Check if price data should be updated.""" """Check if price data should be updated."""
if self._cached_price_data is None: if self._cached_price_data is None:
_LOGGER.debug("Should update: No cached price data")
return True return True
if self._last_price_update is None: if self._last_price_update is None:
_LOGGER.debug("Should update: No last price update timestamp")
return True return True
# Update every 15 minutes
return (current_time - self._last_price_update) >= UPDATE_INTERVAL time_since_update = current_time - self._last_price_update
should_update = time_since_update >= UPDATE_INTERVAL
_LOGGER.debug(
"Should update price data: %s (time since last update: %s, interval: %s)",
should_update,
time_since_update,
UPDATE_INTERVAL,
)
return should_update
@callback @callback
def _merge_cached_data(self) -> dict[str, Any]: def _merge_cached_data(self) -> dict[str, Any]: