diff --git a/packages/helpermodules/pub.py b/packages/helpermodules/pub.py index 1f5f15c2b2..f50d9e1bc8 100644 --- a/packages/helpermodules/pub.py +++ b/packages/helpermodules/pub.py @@ -14,10 +14,13 @@ def __init__(self) -> None: self.publisher.start_loop() def pub(self, topic: str, payload, qos: int = 0, retain: bool = True) -> None: - if payload == "": - self.publisher.client.publish(topic, payload, qos=qos, retain=retain) - else: - self.publisher.client.publish(topic, payload=json.dumps(payload), qos=qos, retain=retain) + try: + if payload == "": + self.publisher.client.publish(topic, payload, qos=qos, retain=retain) + else: + self.publisher.client.publish(topic, payload=json.dumps(payload), qos=qos, retain=retain) + except Exception as e: + log.exception("Fehler beim beim Publish Topic %s: %s", topic, e) class Pub: