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

Uer hass.loop.create_future() for MQTT client (#100053)

Browse Source
This commit is contained in:
Jan Bouwhuis 2023-09-10 17:15:46 +02:00 committed by GitHub
parent 05635c913f
commit 1a5f093397
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
homeassistant/components/mqtt/__init__.py
View File

@ -248,7 +248,7 @@ async def async_setup_entry(hass: HomeAssistant, entry: ConfigEntry) -> bool:
client_available: asyncio.Future[bool] client_available: asyncio.Future[bool]
if DATA_MQTT_AVAILABLE not in hass.data: if DATA_MQTT_AVAILABLE not in hass.data:
client_available = hass.data[DATA_MQTT_AVAILABLE] = asyncio.Future() client_available = hass.data[DATA_MQTT_AVAILABLE] = hass.loop.create_future()
else: else:
client_available = hass.data[DATA_MQTT_AVAILABLE] client_available = hass.data[DATA_MQTT_AVAILABLE]

4
homeassistant/components/mqtt/util.py
View File

@ -63,7 +63,9 @@ async def async_wait_for_mqtt_client(hass: HomeAssistant) -> bool:
state_reached_future: asyncio.Future[bool] state_reached_future: asyncio.Future[bool]
if DATA_MQTT_AVAILABLE not in hass.data: if DATA_MQTT_AVAILABLE not in hass.data:
hass.data[DATA_MQTT_AVAILABLE] = state_reached_future = asyncio.Future() hass.data[
DATA_MQTT_AVAILABLE
] = state_reached_future = hass.loop.create_future()
else: else:
state_reached_future = hass.data[DATA_MQTT_AVAILABLE] state_reached_future = hass.data[DATA_MQTT_AVAILABLE]
if state_reached_future.done(): if state_reached_future.done():