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

Bugfix wait in automation (#4984)

Browse Source
This commit is contained in:
Pascal Vizeli 2016-12-18 21:57:31 +01:00 committed by Paulus Schoutsen
parent 9bc16157af
commit b750319de4
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
homeassistant/components/automation/__init__.py
View File

@ -166,7 +166,9 @@ def async_setup(hass, config):
for entity in component.async_extract_from_service(service_call): for entity in component.async_extract_from_service(service_call):
tasks.append(entity.async_trigger( tasks.append(entity.async_trigger(
service_call.data.get(ATTR_VARIABLES), True)) service_call.data.get(ATTR_VARIABLES), True))
yield from asyncio.wait(tasks, loop=hass.loop)
if tasks:
yield from asyncio.wait(tasks, loop=hass.loop)
@asyncio.coroutine @asyncio.coroutine
def turn_onoff_service_handler(service_call): def turn_onoff_service_handler(service_call):
@ -175,7 +177,9 @@ def async_setup(hass, config):
method = 'async_{}'.format(service_call.service) method = 'async_{}'.format(service_call.service)
for entity in component.async_extract_from_service(service_call): for entity in component.async_extract_from_service(service_call):
tasks.append(getattr(entity, method)()) tasks.append(getattr(entity, method)())
yield from asyncio.wait(tasks, loop=hass.loop)
if tasks:
yield from asyncio.wait(tasks, loop=hass.loop)
@asyncio.coroutine @asyncio.coroutine
def toggle_service_handler(service_call): def toggle_service_handler(service_call):
@ -186,7 +190,9 @@ def async_setup(hass, config):
tasks.append(entity.async_turn_off()) tasks.append(entity.async_turn_off())
else: else:
tasks.append(entity.async_turn_on()) tasks.append(entity.async_turn_on())
yield from asyncio.wait(tasks, loop=hass.loop)
if tasks:
yield from asyncio.wait(tasks, loop=hass.loop)
@asyncio.coroutine @asyncio.coroutine
def reload_service_handler(service_call): def reload_service_handler(service_call):