- removed AtemperatureSensor::process

- task is AttributeChange
- hareden against Tempsensor exceptions
This commit is contained in:
jens
2021-10-19 11:29:11 +02:00
parent bd63f2648c
commit 6e7f8c2c59
6 changed files with 14 additions and 19 deletions
+3 -1
View File
@@ -1,9 +1,11 @@
import abc
import asyncio
from utils.value import AttributeChange
class ATask:
class ATask(AttributeChange):
def __init__(self, interval):
AttributeChange.__init__(self)
self.interval = interval
@abc.abstractmethod
+6 -2
View File
@@ -12,6 +12,7 @@ class TempSensorTask(ATask):
self.msg_handler = msg_handler
msg_handler.set_recv_handler(self.recv)
self.sensor = sensor_device
self.temp = self.sensor.temperature()
def on_temp_changed(self, value):
asyncio.create_task(self.send({'Temp': value}))
@@ -25,7 +26,10 @@ class TempSensorTask(ATask):
async def on_process(self):
print("{}: Started with interval {} s".format(self.msg_handler.get_key(), self.interval))
temp = ChangedFloat(self.on_temp_changed, prec=1)
self.sensor.set_on_changed("temp", temp.set)
self.set_on_changed("temp", temp.set)
while True:
self.sensor.process()
try:
self.temp = self.sensor.temperature()
except Exception:
pass
await asyncio.sleep(self.interval)