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:35:48 -0700 |
| commit | eb4b2b33a5b05cf8405c3a88d435fc3e9747c767 (patch) | |
| tree | b0986bc77ca3a71eb95479f410db1905aa6dd02d | |
| parent | f83d29444118c66723fea70f5cfd7268effb1883 (diff) | |
| download | kafka-python-eb4b2b33a5b05cf8405c3a88d435fc3e9747c767.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): |