From 67cabfed60b6dc2ca21a860a46afce0ce97d8bc3 Mon Sep 17 00:00:00 2001 From: Jeff Hu Date: Tue, 11 Jul 2017 15:41:07 -0400 Subject: [PATCH] fix queue empty bug --- analytics/consumer.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/analytics/consumer.py b/analytics/consumer.py index f49993a1..4d4173d7 100644 --- a/analytics/consumer.py +++ b/analytics/consumer.py @@ -66,7 +66,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)