diff options
author | Dana Powers <dana.powers@rd.io> | 2015-12-30 12:18:02 -0800 |
---|---|---|
committer | Dana Powers <dana.powers@rd.io> | 2015-12-30 12:18:02 -0800 |
commit | 61161d8335bba3f1786f10a321a2a9e915adb286 (patch) | |
tree | 877c1ecaec898455627d327a653c8454b1540c11 /kafka/client_async.py | |
parent | cfae9e3fa3432fad6bbd97c1d81f8ea4bc0ee363 (diff) | |
download | kafka-python-61161d8335bba3f1786f10a321a2a9e915adb286.tar.gz |
Improve removed tasks handing in DelayedTaskQueue.pop_ready
Diffstat (limited to 'kafka/client_async.py')
-rw-r--r-- | kafka/client_async.py | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/kafka/client_async.py b/kafka/client_async.py index eaa5ef0..e2e68a8 100644 --- a/kafka/client_async.py +++ b/kafka/client_async.py @@ -465,8 +465,11 @@ class DelayedTaskQueue(object): def pop_ready(self): """Pop and return a list of all ready (task, future) tuples""" - self._drop_removed() ready_tasks = [] while self._tasks and self._tasks[0][0] < time.time(): - ready_tasks.append(self._pop_next()) + try: + task = self._pop_next() + except KeyError: + break + ready_tasks.append(task) return ready_tasks |