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

Remove redundant Guardian handler unsub logic (#84905)

Browse Source
This commit is contained in:
Aaron Bach 2022-12-31 03:17:37 -07:00 committed by GitHub
parent e141374831
commit fbb406842e
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 5 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
homeassistant/components/guardian/__init__.py
View File

@ -322,10 +322,11 @@ class PairedSensorManager:
"""Define a callback for when new paired sensor data is received.""" """Define a callback for when new paired sensor data is received."""
self._hass.async_create_task(self.async_process_latest_paired_sensor_uids()) self._hass.async_create_task(self.async_process_latest_paired_sensor_uids())
cancel_process_task = self._sensor_pair_dump_coordinator.async_add_listener( self._entry.async_on_unload(
async_create_process_task self._sensor_pair_dump_coordinator.async_add_listener(
async_create_process_task
)
) )
self._entry.async_on_unload(cancel_process_task)
async def async_pair_sensor(self, uid: str) -> None: async def async_pair_sensor(self, uid: str) -> None:
"""Add a new paired sensor coordinator.""" """Add a new paired sensor coordinator."""

11
homeassistant/components/guardian/util.py
View File

@ -87,7 +87,6 @@ class GuardianDataUpdateCoordinator(DataUpdateCoordinator[dict]):
self._api_coro = api_coro self._api_coro = api_coro
self._api_lock = api_lock self._api_lock = api_lock
self._client = client self._client = client
self._signal_handler_unsubs: list[Callable[..., None]] = []
self.config_entry = entry self.config_entry = entry
self.signal_reboot_requested = SIGNAL_REBOOT_REQUESTED.format( self.signal_reboot_requested = SIGNAL_REBOOT_REQUESTED.format(
@ -112,16 +111,8 @@ class GuardianDataUpdateCoordinator(DataUpdateCoordinator[dict]):
self.last_update_success = False self.last_update_success = False
self.async_update_listeners() self.async_update_listeners()
self._signal_handler_unsubs.append( self.config_entry.async_on_unload(
async_dispatcher_connect( async_dispatcher_connect(
self.hass, self.signal_reboot_requested, async_reboot_requested self.hass, self.signal_reboot_requested, async_reboot_requested
) )
) )
@callback
def async_teardown() -> None:
"""Tear the coordinator down appropriately."""
for unsub in self._signal_handler_unsubs:
unsub()
self.config_entry.async_on_unload(async_teardown)