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

Fix async knocki function (#121048)

Browse Source
This commit is contained in:
Joost Lekkerkerker 2024-07-03 17:17:37 +02:00 committed by GitHub
parent 7a9792c111
commit bc363c385f
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
homeassistant/components/knocki/coordinator.py
View File

@ -3,7 +3,7 @@
from knocki import Event, KnockiClient, KnockiConnectionError, Trigger from knocki import Event, KnockiClient, KnockiConnectionError, Trigger
from homeassistant.components.event import DOMAIN as EVENT_DOMAIN from homeassistant.components.event import DOMAIN as EVENT_DOMAIN
from homeassistant.core import HomeAssistant from homeassistant.core import HomeAssistant, callback
from homeassistant.helpers import entity_registry as er from homeassistant.helpers import entity_registry as er
from homeassistant.helpers.update_coordinator import DataUpdateCoordinator, UpdateFailed from homeassistant.helpers.update_coordinator import DataUpdateCoordinator, UpdateFailed
@ -33,7 +33,7 @@ class KnockiCoordinator(DataUpdateCoordinator[dict[int, Trigger]]):
} }
removed_triggers = self._known_triggers - current_triggers removed_triggers = self._known_triggers - current_triggers
for trigger in removed_triggers: for trigger in removed_triggers:
await self._delete_device(trigger) self._async_delete_device(trigger)
self._known_triggers = current_triggers self._known_triggers = current_triggers
return {trigger.details.trigger_id: trigger for trigger in triggers} return {trigger.details.trigger_id: trigger for trigger in triggers}
@ -46,7 +46,8 @@ class KnockiCoordinator(DataUpdateCoordinator[dict[int, Trigger]]):
(event.payload.device_id, event.payload.details.trigger_id) (event.payload.device_id, event.payload.details.trigger_id)
) )
async def _delete_device(self, trigger: tuple[str, int]) -> None: @callback
def _async_delete_device(self, trigger: tuple[str, int]) -> None:
"""Delete a device from the coordinator.""" """Delete a device from the coordinator."""
device_id, trigger_id = trigger device_id, trigger_id = trigger
entity_registry = er.async_get(self.hass) entity_registry = er.async_get(self.hass)