This commit is contained in:
Nick Mowen 2022-11-22 15:30:57 -07:00
parent 5a32cd1977
commit 2d94c1963c

View File

@ -120,7 +120,9 @@ class MqttClient(Communicator): # type: ignore[misc]
client.subscribe(f"{self.mqtt_config.topic_prefix}/#")
self._set_initial_topics()
def _on_disconnect(self, client: mqtt.Client, userdata: mqtt._UserData, flags: Any, rc: mqtt) -> None:
def _on_disconnect(
self, client: mqtt.Client, userdata: mqtt._UserData, flags: Any, rc: mqtt
) -> None:
"""Mqtt disconnection callback."""
self.connected = False
logger.error("MQTT disconnected")