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

Avoid calling async code in sync context (#23235)

Browse Source
This commit is contained in:
Jc2k 2019-04-19 18:59:54 +01:00 committed by Jason Hu
parent 9cf9be8850
commit e7054e0fd2
1 changed files with 10 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
homeassistant/components/homekit_controller/connection.py
View File

@ -101,25 +101,27 @@ class HKDevice():
return True return True
async def async_refresh_entity_map(self, config_num): def refresh_entity_map(self, config_num):
""" """
Handle setup of a HomeKit accessory. Handle setup of a HomeKit accessory.
The sync version will be removed when homekit_controller migrates to The sync version will be removed when homekit_controller migrates to
config flow. config flow.
""" """
return await self.hass.async_add_executor_job( self.hass.add_job(
self.refresh_entity_map, self.async_refresh_entity_map,
config_num, config_num,
) )
def refresh_entity_map(self, config_num): async def async_refresh_entity_map(self, config_num):
"""Handle setup of a HomeKit accessory.""" """Handle setup of a HomeKit accessory."""
# pylint: disable=import-error # pylint: disable=import-error
from homekit.exceptions import AccessoryDisconnectedError from homekit.exceptions import AccessoryDisconnectedError
try: try:
accessories = self.pairing.list_accessories_and_characteristics() self.accessories = await self.hass.async_add_executor_job(
self.pairing.list_accessories_and_characteristics,
)
except AccessoryDisconnectedError: except AccessoryDisconnectedError:
# If we fail to refresh this data then we will naturally retry # If we fail to refresh this data then we will naturally retry
# later when Bonjour spots c# is still not up to date. # later when Bonjour spots c# is still not up to date.
@ -128,18 +130,17 @@ class HKDevice():
self.hass.data[ENTITY_MAP].async_create_or_update_map( self.hass.data[ENTITY_MAP].async_create_or_update_map(
self.unique_id, self.unique_id,
config_num, config_num,
accessories, self.accessories,
) )
self.accessories = accessories
self.config_num = config_num self.config_num = config_num
# For BLE, the Pairing instance relies on the entity map to map # For BLE, the Pairing instance relies on the entity map to map
# aid/iid to GATT characteristics. So push it to there as well. # aid/iid to GATT characteristics. So push it to there as well.
self.pairing.pairing_data['accessories'] = accessories self.pairing.pairing_data['accessories'] = self.accessories
# Register add new entities that are available # Register add new entities that are available
self.add_entities() await self.hass.async_add_executor_job(self.add_entities)
return True return True