From 3d26ac332390bed6a1bf86d4e49755034dfb5f4e Mon Sep 17 00:00:00 2001 From: Pascal Vizeli Date: Mon, 27 Feb 2017 00:28:54 +0100 Subject: [PATCH] Bugfix mqtt paho client to speend time (#6266) --- homeassistant/components/mqtt/__init__.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/homeassistant/components/mqtt/__init__.py b/homeassistant/components/mqtt/__init__.py index 238d3c09146..38e4fd18b28 100644 --- a/homeassistant/components/mqtt/__init__.py +++ b/homeassistant/components/mqtt/__init__.py @@ -436,6 +436,7 @@ class MQTT(object): with (yield from self._paho_lock): yield from self.hass.loop.run_in_executor( None, self._mqttc.publish, topic, payload, qos, retain) + yield from asyncio.sleep(0, loop=self.hass.loop) @asyncio.coroutine def async_connect(self): @@ -486,6 +487,7 @@ class MQTT(object): with (yield from self._paho_lock): result, mid = yield from self.hass.loop.run_in_executor( None, self._mqttc.subscribe, topic, qos) + yield from asyncio.sleep(0, loop=self.hass.loop) _raise_on_error(result) self.progress[mid] = topic