FIX: queue.get() interface

panta · panta · commit d920d7154044 · 2017-11-09T09:05:21.000+01:00
diff --git a/fluent/asyncsender.py b/fluent/asyncsender.py
@@ -66,7 +66,7 @@ def send(self, bytes_):
     def run(self):
         while self._do_run:
             try:
-                bytes_ = self._queue.get(block=False, timeout=self._queue_timeout)
+                bytes_ = self._queue.get(block=True, timeout=self._queue_timeout)
             except Empty:
                 continue
             self._conn_close_lock.acquire()
