Merge branch 'release/0.7.1'

snowplow · Aug 11, 2015 · 00e7515 · 00e7515
2 parents a1e4333 + 7659c65
commit 00e7515
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 2 deletions.
diff --git a/CHANGES.txt b/CHANGES.txt
@@ -1,3 +1,7 @@
+Version 0.7.0 (2015-08-11)
+--------------------------
+Ensured synchronous flush always waits for the task queue to empty (#142)
+
 Version 0.7.0 (2015-08-07)
 --------------------------
 Added SelfDescribingJson class (#140)

diff --git a/snowplow_tracker/_version.py b/snowplow_tracker/_version.py
@@ -20,5 +20,5 @@
 """
 
 
-__version_info__ = (0, 7, 0)
+__version_info__ = (0, 7, 1)
 __version__ = ".".join(str(x) for x in __version_info__)
diff --git a/snowplow_tracker/emitters.py b/snowplow_tracker/emitters.py
@@ -292,9 +292,11 @@ def __init__(
             t.start()
 
     def sync_flush(self):
-        while len(self.buffer) > 0:
+        while True:
             self.flush()
             self.queue.join()
+            if len(self.buffer) < 1:
+                break
 
     def flush(self):
         """