Move raise on MQTT publish outside lock (#92860)
* Move raise outside lock * Move log toopull/92879/head
parent
5d6ccd6a32
commit
9e9073d5da
|
@ -465,15 +465,15 @@ class MQTT:
|
|||
msg_info = await self.hass.async_add_executor_job(
|
||||
self._mqttc.publish, topic, payload, qos, retain
|
||||
)
|
||||
_LOGGER.debug(
|
||||
"Transmitting%s message on %s: '%s', mid: %s, qos: %s",
|
||||
" retained" if retain else "",
|
||||
topic,
|
||||
payload,
|
||||
msg_info.mid,
|
||||
qos,
|
||||
)
|
||||
_raise_on_error(msg_info.rc)
|
||||
_LOGGER.debug(
|
||||
"Transmitting%s message on %s: '%s', mid: %s, qos: %s",
|
||||
" retained" if retain else "",
|
||||
topic,
|
||||
payload,
|
||||
msg_info.mid,
|
||||
qos,
|
||||
)
|
||||
_raise_on_error(msg_info.rc)
|
||||
await self._wait_for_mid(msg_info.mid)
|
||||
|
||||
async def async_connect(self) -> None:
|
||||
|
|
Loading…
Reference in New Issue