Do not clear cache for each attribute (#52)
This commit is contained in:
+2
-7
@@ -11,9 +11,8 @@ class MifloraWorker(BaseWorker):
|
|||||||
from miflora.miflora_poller import MiFloraPoller
|
from miflora.miflora_poller import MiFloraPoller
|
||||||
from btlewrap.bluepy import BluepyBackend
|
from btlewrap.bluepy import BluepyBackend
|
||||||
|
|
||||||
|
|
||||||
for name, mac in self.devices.items():
|
for name, mac in self.devices.items():
|
||||||
self.devices[name] = MiFloraPoller(mac, BluepyBackend, cache_timeout=0)
|
self.devices[name] = MiFloraPoller(mac, BluepyBackend)
|
||||||
|
|
||||||
def status_update(self):
|
def status_update(self):
|
||||||
ret = []
|
ret = []
|
||||||
@@ -22,16 +21,12 @@ class MifloraWorker(BaseWorker):
|
|||||||
ret += self.update_device_state(name, poller)
|
ret += self.update_device_state(name, poller)
|
||||||
except RuntimeError:
|
except RuntimeError:
|
||||||
pass
|
pass
|
||||||
|
|
||||||
return ret
|
return ret
|
||||||
|
|
||||||
@timeout(8.0)
|
@timeout(8.0)
|
||||||
|
|
||||||
def update_device_state(self, name, poller):
|
def update_device_state(self, name, poller):
|
||||||
|
|
||||||
ret = []
|
ret = []
|
||||||
|
poller.clear_cache()
|
||||||
for attr in monitoredAttrs:
|
for attr in monitoredAttrs:
|
||||||
|
|
||||||
ret.append(MqttMessage(topic=self.format_topic(name, attr), payload=poller.parameter_value(attr)))
|
ret.append(MqttMessage(topic=self.format_topic(name, attr), payload=poller.parameter_value(attr)))
|
||||||
|
|
||||||
return ret
|
return ret
|
||||||
|
|||||||
Reference in New Issue
Block a user