administrator/frigate
1
0
Fork 0
mirror of https://github.com/blakeblackshear/frigate.git synced 2026-02-17 00:25:23 +03:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

Adjust mqtt logging behavior

Browse Source
This commit is contained in:
Nicolas Mowen 2024-10-25 08:28:54 -06:00
parent 4c75440af4
commit 5d35433dd0
1 changed files with 1 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
frigate/comms/mqtt.py
View File

@ -18,7 +18,6 @@ class MqttClient(Communicator): # type: ignore[misc]
self.config = config self.config = config
self.mqtt_config = config.mqtt self.mqtt_config = config.mqtt
self.connected = False self.connected = False
self.started = False
def subscribe(self, receiver: Callable) -> None: def subscribe(self, receiver: Callable) -> None:
"""Wrapper for allowing dispatcher to subscribe.""" """Wrapper for allowing dispatcher to subscribe."""
@ -28,8 +27,7 @@ class MqttClient(Communicator): # type: ignore[misc]
def publish(self, topic: str, payload: Any, retain: bool = False) -> None: def publish(self, topic: str, payload: Any, retain: bool = False) -> None:
"""Wrapper for publishing when client is in valid state.""" """Wrapper for publishing when client is in valid state."""
if not self.connected: if not self.connected:
if self.started: logger.debug(f"Unable to publish to {topic}: client is not connected")
logger.error(f"Unable to publish to {topic}: client is not connected")
return return
self.client.publish( self.client.publish(
@ -247,7 +245,6 @@ class MqttClient(Communicator): # type: ignore[misc]
# with connect_async, retries are handled automatically # with connect_async, retries are handled automatically
self.client.connect_async(self.mqtt_config.host, self.mqtt_config.port, 60) self.client.connect_async(self.mqtt_config.host, self.mqtt_config.port, 60)
self.client.loop_start() self.client.loop_start()
self.started = True
except Exception as e: except Exception as e:
logger.error(f"Unable to connect to MQTT server: {e}") logger.error(f"Unable to connect to MQTT server: {e}")
return return