Merge pull request #19 from tinybirdco/stop-flush-with-every-upload

stop flush with every event

Author: ricardotinybird

clickhouse_mysql/pool/bbpool.py

@@ -33,11 +33,11 @@ class BBPool(Pool):
     }
 
     buckets_num_total = 0
-    items_num_total = 0;
+    items_num_total = 0
 
     prev_time = None
     prev_buckets_count = 0
-    prev_items_count = 0;
+    prev_items_count = 0
 
     def __init__(
             self,
@@ -63,7 +63,6 @@ def create_belt(self, belt_index):
 
     def insert(self, item):
         """Insert item into pool"""
-
         # which belt we'll insert item?
         belt_index = self.key_generator.generate(item)
 
@@ -85,10 +84,10 @@ def flush(self, key=None):
 
         if belt_index is None:
             for b_index in self.belts:
-                if self.rotate_belt(b_index, flush=True):
+                if self.rotate_belt(b_index, flush=False):
                     empty_belts_indexes.append(b_index)
         else:
-            if self.rotate_belt(belt_index, flush=True):
+            if self.rotate_belt(belt_index, flush=False):
                 empty_belts_indexes.append(belt_index)
 
         # delete belt