Correctly call on_update function with hass.add_job so it runs on the correct thread

This commit is contained in:
Niek Schoemaker 2025-01-16 13:52:48 +01:00
parent 6ffb7a4901
commit 3325bb27b9
No known key found for this signature in database
GPG key ID: BDF9404CFECB0006

View file

@ -48,7 +48,7 @@ async def async_setup_entry(hass: HomeAssistant, entry: ConfigEntry) -> bool:
coordinator: DataUpdateCoordinator[dict[str, Any]] = DataUpdateCoordinator(
hass, _LOGGER, name=DOMAIN
)
hon.subscribe_updates(coordinator.async_set_updated_data)
hon.subscribe_updates(lambda data: hass.add_job(coordinator.async_set_updated_data, data))
hass.data.setdefault(DOMAIN, {})
hass.data[DOMAIN][entry.unique_id] = {"hon": hon, "coordinator": coordinator}