evlli/hass-core
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Fix lingering timer in discovery (#91804)

Browse source 
* Fix lingering timer in discovery

* type hint
This commit is contained in:
epenet 2023-04-21 11:49:10 +02:00 • committed by GitHub
parent 2198492f1b
commit 459af7f834
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 8 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
homeassistant/components/discovery/__init__.py
View file

@ -1,7 +1,7 @@
"""Starts a service to scan in intervals for new devices."""
from __future__ import annotations
from datetime import timedelta
from datetime import datetime, timedelta
import json
import logging
from typing import NamedTuple
@ -12,7 +12,7 @@ import voluptuous as vol
from homeassistant import config_entries
from homeassistant.components import zeroconf
from homeassistant.const import EVENT_HOMEASSISTANT_STARTED
from homeassistant.core import HomeAssistant, callback
from homeassistant.core import Event, HassJob, HomeAssistant, callback
from homeassistant.helpers import discovery_flow
import homeassistant.helpers.config_validation as cv
from homeassistant.helpers.discovery import async_discover, async_load_platform
@ -202,7 +202,7 @@ async def async_setup(hass: HomeAssistant, config: ConfigType) -> bool:
hass, service_details.component, service_details.platform, info, config
)
async def scan_devices(now):
async def scan_devices(now: datetime) -> None:
"""Scan for devices."""
try:
results = await hass.async_add_executor_job(
@ -215,13 +215,15 @@ async def async_setup(hass: HomeAssistant, config: ConfigType) -> bool:
logger.error("Network is unreachable")
async_track_point_in_utc_time(
hass, scan_devices, dt_util.utcnow() + SCAN_INTERVAL
hass, scan_devices_job, dt_util.utcnow() + SCAN_INTERVAL
)
@callback
def schedule_first(event):
def schedule_first(event: Event) -> None:
"""Schedule the first discovery when Home Assistant starts up."""
async_track_point_in_utc_time(hass, scan_devices, dt_util.utcnow())
async_track_point_in_utc_time(hass, scan_devices_job, dt_util.utcnow())
scan_devices_job = HassJob(scan_devices, cancel_on_shutdown=True)
hass.bus.async_listen_once(EVENT_HOMEASSISTANT_STARTED, schedule_first)