Adjust async_track_time_interval name argument (#90838)

Adjust async_track_time_interval naming
pull/90855/head
epenet 2023-04-05 16:58:02 +02:00 committed by Franck Nijhof
parent 0d019a3c4c
commit fb2d432d32
No known key found for this signature in database
GPG Key ID: D62583BA8AB11CA3
15 changed files with 26 additions and 18 deletions

View File

@ -28,7 +28,7 @@ async def async_setup(hass: HomeAssistant, _: ConfigType) -> bool:
# Send every day
async_track_time_interval(
hass, analytics.send_analytics, INTERVAL, "analytics daily"
hass, analytics.send_analytics, INTERVAL, name="analytics daily"
)
hass.bus.async_listen_once(EVENT_HOMEASSISTANT_STARTED, start_schedule)

View File

@ -38,7 +38,10 @@ class AugustSubscriberMixin:
def _async_setup_listeners(self):
"""Create interval and stop listeners."""
self._unsub_interval = async_track_time_interval(
self._hass, self._async_refresh, self._update_interval, "august refresh"
self._hass,
self._async_refresh,
self._update_interval,
name="august refresh",
)
@callback

View File

@ -101,7 +101,7 @@ class BaseHaScanner(ABC):
self.hass,
self._async_scanner_watchdog,
SCANNER_WATCHDOG_INTERVAL,
f"{self.name} Bluetooth scanner watchdog",
name=f"{self.name} Bluetooth scanner watchdog",
)
@hass_callback
@ -230,7 +230,7 @@ class BaseHaRemoteScanner(BaseHaScanner):
self.hass,
self._async_expire_devices,
timedelta(seconds=30),
f"{self.name} Bluetooth scanner device expire",
name=f"{self.name} Bluetooth scanner device expire",
)
cancel_stop = self.hass.bus.async_listen(
EVENT_HOMEASSISTANT_STOP, self._async_save_history

View File

@ -276,7 +276,7 @@ class BluetoothManager:
self.hass,
self._async_check_unavailable,
timedelta(seconds=UNAVAILABLE_TRACK_SECONDS),
"Bluetooth manager unavailable tracking",
name="Bluetooth manager unavailable tracking",
)
@hass_callback

View File

@ -177,7 +177,7 @@ class BondEntity(Entity):
self.hass,
self._async_update_if_bpup_not_alive,
_FALLBACK_SCAN_INTERVAL,
f"Bond {self.entity_id} fallback polling",
name=f"Bond {self.entity_id} fallback polling",
)
)

View File

@ -380,7 +380,7 @@ async def async_setup(hass: HomeAssistant, config: ConfigType) -> bool:
entity.async_write_ha_state()
unsub = async_track_time_interval(
hass, update_tokens, TOKEN_CHANGE_INTERVAL, "Camera update tokens"
hass, update_tokens, TOKEN_CHANGE_INTERVAL, name="Camera update tokens"
)
@callback

View File

@ -427,7 +427,7 @@ def async_setup_scanner_platform(
hass,
async_device_tracker_scan,
interval,
f"device_tracker {platform} legacy scan",
name=f"device_tracker {platform} legacy scan",
)
hass.async_create_task(async_device_tracker_scan(None))

View File

@ -260,7 +260,10 @@ class NetworkWatcher(WatcherBase):
"""Start scanning for new devices on the network."""
self._discover_hosts = DiscoverHosts()
self._unsub = async_track_time_interval(
self.hass, self.async_start_discover, SCAN_INTERVAL, "DHCP network watcher"
self.hass,
self.async_start_discover,
SCAN_INTERVAL,
name="DHCP network watcher",
)
self.async_start_discover()

View File

@ -272,7 +272,8 @@ class HKDevice:
self.hass,
self.async_update_available_state,
timedelta(seconds=BLE_AVAILABILITY_CHECK_INTERVAL),
f"HomeKit Controller {self.unique_id} BLE availability check poll",
name=f"HomeKit Controller {self.unique_id} BLE availability "
"check poll",
)
)
# BLE devices always get an RSSI sensor as well
@ -290,7 +291,7 @@ class HKDevice:
self.hass,
self.async_request_update,
self.pairing.poll_interval,
f"HomeKit Controller {self.unique_id} availability check poll",
name=f"HomeKit Controller {self.unique_id} availability check poll",
)
)

View File

@ -299,7 +299,7 @@ class Recorder(threading.Thread):
self.hass,
self._async_check_queue,
timedelta(minutes=10),
"Recorder queue watcher",
name="Recorder queue watcher",
)
@callback
@ -602,7 +602,7 @@ class Recorder(threading.Thread):
self.hass,
self._async_keep_alive,
timedelta(seconds=KEEPALIVE_TIME),
"Recorder keep alive",
name="Recorder keep alive",
)
# If the commit interval is not 0, we need to commit periodically
@ -611,7 +611,7 @@ class Recorder(threading.Thread):
self.hass,
self._async_commit,
timedelta(seconds=self.commit_interval),
"Recorder commit",
name="Recorder commit",
)
# Run nightly tasks at 4:12am

View File

@ -401,7 +401,7 @@ class Scanner:
self.hass.bus.async_listen_once(EVENT_HOMEASSISTANT_STOP, self.async_stop)
self._cancel_scan = async_track_time_interval(
self.hass, self.async_scan, SCAN_INTERVAL, "SSDP scanner"
self.hass, self.async_scan, SCAN_INTERVAL, name="SSDP scanner"
)
# Trigger the initial-scan.

View File

@ -479,7 +479,7 @@ class EntityPlatform:
self.hass,
self._update_entity_states,
self.scan_interval,
f"EntityPlatform poll {self.domain}.{self.platform_name}",
name=f"EntityPlatform poll {self.domain}.{self.platform_name}",
)
def _entity_id_already_exists(self, entity_id: str) -> tuple[bool, bool]:

View File

@ -1397,6 +1397,7 @@ def async_track_time_interval(
hass: HomeAssistant,
action: Callable[[datetime], Coroutine[Any, Any, None] | None],
interval: timedelta,
*,
name: str | None = None,
) -> CALLBACK_TYPE:
"""Add a listener that fires repetitively at every timedelta interval."""

View File

@ -219,7 +219,7 @@ class RestoreStateData:
self.hass,
_async_dump_states,
STATE_DUMP_INTERVAL,
"RestoreStateData dump states",
name="RestoreStateData dump states",
)
async def _async_dump_states_at_stop(*_: Any) -> None:

View File

@ -3452,7 +3452,7 @@ async def test_track_time_interval_name(hass: HomeAssistant) -> None:
hass,
callback(lambda x: specific_runs.append(x)),
timedelta(seconds=10),
unique_string,
name=unique_string,
)
scheduled = getattr(hass.loop, "_scheduled")
assert any(handle for handle in scheduled if unique_string in str(handle))