Bugfix asyncio wait (#4946)

This commit is contained in:
Pascal Vizeli 2016-12-16 17:36:50 +01:00 committed by Paulus Schoutsen
parent 32dc518971
commit 8358ab56ea
3 changed files with 10 additions and 5 deletions

View File

@ -95,6 +95,7 @@ def async_setup(hass, config):
attr = 'async_toggle' attr = 'async_toggle'
tasks = [getattr(input_b, attr)() for input_b in target_inputs] tasks = [getattr(input_b, attr)() for input_b in target_inputs]
if tasks:
yield from asyncio.wait(tasks, loop=hass.loop) yield from asyncio.wait(tasks, loop=hass.loop)
hass.services.async_register( hass.services.async_register(

View File

@ -113,6 +113,7 @@ def async_setup(hass, config):
tasks = [input_select.async_select_option(call.data[ATTR_OPTION]) tasks = [input_select.async_select_option(call.data[ATTR_OPTION])
for input_select in target_inputs] for input_select in target_inputs]
if tasks:
yield from asyncio.wait(tasks, loop=hass.loop) yield from asyncio.wait(tasks, loop=hass.loop)
hass.services.async_register( hass.services.async_register(
@ -126,6 +127,7 @@ def async_setup(hass, config):
tasks = [input_select.async_offset_index(1) tasks = [input_select.async_offset_index(1)
for input_select in target_inputs] for input_select in target_inputs]
if tasks:
yield from asyncio.wait(tasks, loop=hass.loop) yield from asyncio.wait(tasks, loop=hass.loop)
hass.services.async_register( hass.services.async_register(
@ -139,6 +141,7 @@ def async_setup(hass, config):
tasks = [input_select.async_offset_index(-1) tasks = [input_select.async_offset_index(-1)
for input_select in target_inputs] for input_select in target_inputs]
if tasks:
yield from asyncio.wait(tasks, loop=hass.loop) yield from asyncio.wait(tasks, loop=hass.loop)
hass.services.async_register( hass.services.async_register(

View File

@ -105,6 +105,7 @@ def async_setup(hass, config):
tasks = [input_slider.async_select_value(call.data[ATTR_VALUE]) tasks = [input_slider.async_select_value(call.data[ATTR_VALUE])
for input_slider in target_inputs] for input_slider in target_inputs]
if tasks:
yield from asyncio.wait(tasks, loop=hass.loop) yield from asyncio.wait(tasks, loop=hass.loop)
hass.services.async_register( hass.services.async_register(