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

Ensure status is correct at start for older august bridges (#64144)

Browse Source
This commit is contained in:
J. Nick Koston 2022-01-14 21:00:44 -10:00 committed by GitHub
parent 06329a2f43
commit d1831748eb
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 11 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
homeassistant/components/august/__init__.py
View File

@ -141,9 +141,15 @@ class AugustData(AugustSubscriberMixin):
self._pubnub_unsub = async_create_pubnub(user_data["UserID"], pubnub) self._pubnub_unsub = async_create_pubnub(user_data["UserID"], pubnub)
if self._locks_by_id: if self._locks_by_id:
await asyncio.gather( tasks = []
*[self.async_status_async(lock_id) for lock_id in self._locks_by_id] for lock_id in self._locks_by_id:
) detail = self._device_detail_by_id[lock_id]
tasks.append(
self.async_status_async(
lock_id, bool(detail.bridge and detail.bridge.hyper_bridge)
)
)
await asyncio.gather(*tasks)
@callback @callback
def async_pubnub_message(self, device_id, date_time, message): def async_pubnub_message(self, device_id, date_time, message):
@ -252,13 +258,14 @@ class AugustData(AugustSubscriberMixin):
device_id, device_id,
) )
async def async_status_async(self, device_id): async def async_status_async(self, device_id, hyper_bridge):
"""Request status of the the device but do not wait for a response since it will come via pubnub.""" """Request status of the the device but do not wait for a response since it will come via pubnub."""
return await self._async_call_api_op_requires_bridge( return await self._async_call_api_op_requires_bridge(
device_id, device_id,
self._api.async_status_async, self._api.async_status_async,
self._august_gateway.access_token, self._august_gateway.access_token,
device_id, device_id,
hyper_bridge,
) )
async def async_lock_async(self, device_id, hyper_bridge): async def async_lock_async(self, device_id, hyper_bridge):