dev

plot/refill/WriterConsumer.py

@@ -10,7 +10,7 @@ class WriterConsumer(Thread):
         self._messages = Queue()
         self._stopped = False
         self._handler = handler
-        self._max_threshold = 3000
+        self._max_threshold  = 5000
         self._max_batch_size = 200000
         self._name = name
 
@@ -38,7 +38,7 @@ class WriterConsumer(Thread):
                     continue
                 if path not in batches:
                     batches[path] = list()
-                batches[path].append((method,params))
+                batches[path].append((method, params))
                 count += 1
         except Empty as ex:
             log.info("%s consumer queue is empty", self._name)