blacklight/platypush
1
0
Fork 0
forked from platypush/platypush
Code Issues Pull requests Projects Releases Packages Wiki Activity

Reset the timer as soon as you start processing the batch

Browse source
This commit is contained in:
Fabio Manganiello 2018-07-25 02:21:38 +02:00
parent 6dc86635a4
commit b777bbcfa8
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
platypush/plugins/adafruit/io.py
View file

@ -95,13 +95,13 @@ class AdafruitIoPlugin(Plugin):
if data and (last_processed_batch_timestamp is None or if data and (last_processed_batch_timestamp is None or
time.time() - last_processed_batch_timestamp >= self.throttle_seconds): time.time() - last_processed_batch_timestamp >= self.throttle_seconds):
last_processed_batch_timestamp = time.time()
self.logger.info('Processing feeds batch for Adafruit IO') self.logger.info('Processing feeds batch for Adafruit IO')
for (feed, values) in data.items(): for (feed, values) in data.items():
if values: if values:
self.send(feed, values, enqueue=False) self.send(feed, values, enqueue=False)
last_processed_batch_timestamp = time.time()
data = {} data = {}
return run return run