This commit is contained in:
avollkopf 2023-03-25 13:25:07 +01:00
parent 5f24e2d149
commit 848fb4e778

View file

@ -25,6 +25,9 @@ class MQTTSensor(CBPiSensor):
if self.payload_text != None: if self.payload_text != None:
self.payload_text = self.payload_text.split('.') self.payload_text = self.payload_text.split('.')
self.mqtt_task = self.cbpi.satellite.subcribe(self.Topic, self.on_message) self.mqtt_task = self.cbpi.satellite.subcribe(self.Topic, self.on_message)
async def start(self):
await super().start()
self.value: float = 999 self.value: float = 999
self.timeout=int(self.props.get("Timeout", 60)) self.timeout=int(self.props.get("Timeout", 60))
self.starttime = time.time() self.starttime = time.time()