fix queue empty bug (#98)

segmentio · Sep 21, 2017 · e076ccd · e076ccd
1 parent 8c4b39a
commit e076ccd
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/analytics/consumer.py b/analytics/consumer.py
@@ -67,7 +67,7 @@ def next(self):
         queue = self.queue
         items = []
 
-        while len(items) < self.upload_size or self.queue.empty():
+        while len(items) < self.upload_size:
             try:
                 item = queue.get(block=True, timeout=0.5)
                 items.append(item)