diff options
| author | Dana Powers <dana.powers@gmail.com> | 2016-03-13 08:48:08 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2016-03-13 09:31:18 -0700 |
| commit | afce25267d8423a4fc3aab10ce2edfaa19b7ce44 (patch) | |
| tree | 902fa0a023e93612f878f814ce94ec8898ccee89 | |
| parent | e42383dd84520b1087c0a64ae1017fe4b69eeef7 (diff) | |
| download | kafka-python-afce25267d8423a4fc3aab10ce2edfaa19b7ce44.tar.gz | |
Fix for FutureProduceResult.await on python2.6
| -rw-r--r-- | kafka/producer/future.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/kafka/producer/future.py b/kafka/producer/future.py index 52c4ffc..5a7a9dc 100644 --- a/kafka/producer/future.py +++ b/kafka/producer/future.py @@ -25,7 +25,8 @@ class FutureProduceResult(Future): return ret def await(self, timeout=None): - return self._latch.wait(timeout) + # wait() on python2.6 returns None instead of the flag value + return self._latch.wait(timeout) or self._latch.is_set() class FutureRecordMetadata(Future): |