From 31ddcc6278f1439f383a6672bd3a9078d4892904 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 94fc7cc85f0..e8616e22761 100644 --- a/homeassistant/components/mqtt/__init__.py +++ b/homeassistant/components/mqtt/__init__.py @@ -437,6 +437,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): @@ -487,6 +488,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