dev

plot/refill/WriterConsumer.py

@@ -18,11 +18,10 @@ class WriterConsumer(Thread):
         while True:
             size = self._messages.qsize()
             log.debug("%s messages size=%d", self._name, size)
-            self._single()
-            # if size > self._max_threshold:
-            #     self._batch()
-            # else:
-            #     self._single()
+            if size > self._max_threshold:
+                self._batch()
+            else:
+                self._single()
 
             if self._stopped and self._messages.empty():
                 break