jeans/core
jeans/core
1
0
Fork 0
mirror of https://github.com/home-assistant/core.git synced 2025-07-23 13:17:32 +00:00
Code Issues Packages Projects Releases Wiki Activity

Use entry.async_on_unload in fireservicerota (#138360)

Browse Source
This commit is contained in:
epenet 2025-02-12 09:22:35 +01:00 committed by GitHub
parent a6c51440e5
commit 2033dbdd90
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
homeassistant/components/fireservicerota/__init__.py
View File

@ -27,6 +27,7 @@ async def async_setup_entry(hass: HomeAssistant, entry: ConfigEntry) -> bool:
if client.token_refresh_failure: if client.token_refresh_failure:
return False return False
entry.async_on_unload(client.async_stop_listener)
coordinator = FireServiceUpdateCoordinator(hass, client, entry) coordinator = FireServiceUpdateCoordinator(hass, client, entry)
await coordinator.async_config_entry_first_refresh() await coordinator.async_config_entry_first_refresh()
@ -43,10 +44,6 @@ async def async_setup_entry(hass: HomeAssistant, entry: ConfigEntry) -> bool:
async def async_unload_entry(hass: HomeAssistant, entry: ConfigEntry) -> bool: async def async_unload_entry(hass: HomeAssistant, entry: ConfigEntry) -> bool:
"""Unload FireServiceRota config entry.""" """Unload FireServiceRota config entry."""
await hass.async_add_executor_job(
hass.data[DOMAIN][entry.entry_id][DATA_CLIENT].websocket.stop_listener
)
unload_ok = await hass.config_entries.async_unload_platforms(entry, PLATFORMS) unload_ok = await hass.config_entries.async_unload_platforms(entry, PLATFORMS)
if unload_ok: if unload_ok:
del hass.data[DOMAIN][entry.entry_id] del hass.data[DOMAIN][entry.entry_id]

4
homeassistant/components/fireservicerota/coordinator.py
View File

@ -213,3 +213,7 @@ class FireServiceRotaClient:
) )
await self.update_call(self.fsr.set_incident_response, self.incident_id, value) await self.update_call(self.fsr.set_incident_response, self.incident_id, value)
async def async_stop_listener(self) -> None:
"""Stop listener."""
await self._hass.async_add_executor_job(self.websocket.stop_listener)