From 50382a609c7270baff481c7190ad02f3b1359c0e Mon Sep 17 00:00:00 2001 From: "J. Nick Koston" Date: Sun, 10 Sep 2023 11:24:57 -0500 Subject: [PATCH] Create recorder futures with loop.create_future() (#100049) --- homeassistant/components/recorder/core.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/homeassistant/components/recorder/core.py b/homeassistant/components/recorder/core.py index bbaff24ff77..8aa2bce96b1 100644 --- a/homeassistant/components/recorder/core.py +++ b/homeassistant/components/recorder/core.py @@ -187,7 +187,7 @@ class Recorder(threading.Thread): self.auto_purge = auto_purge self.auto_repack = auto_repack self.keep_days = keep_days - self._hass_started: asyncio.Future[object] = asyncio.Future() + self._hass_started: asyncio.Future[object] = hass.loop.create_future() self.commit_interval = commit_interval self._queue: queue.SimpleQueue[RecorderTask] = queue.SimpleQueue() self.db_url = uri @@ -198,7 +198,7 @@ class Recorder(threading.Thread): db_connected: asyncio.Future[bool] = hass.data[DOMAIN].db_connected self.async_db_connected: asyncio.Future[bool] = db_connected # Database is ready to use but live migration may be in progress - self.async_db_ready: asyncio.Future[bool] = asyncio.Future() + self.async_db_ready: asyncio.Future[bool] = hass.loop.create_future() # Database is ready to use and all migration steps completed (used by tests) self.async_recorder_ready = asyncio.Event() self._queue_watch = threading.Event()