openstack/deb-python-kafka
Code Issues Proposed changes

Fix for FutureProduceResult.await on python2.6

Browse Source
This commit is contained in:
Dana Powers
2016-03-13 08:48:08 -07:00
parent e42383dd84
commit afce25267d
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
kafka/producer/future.py
View File

@@ -25,7 +25,8 @@ class FutureProduceResult(Future):
return ret return ret
def await(self, timeout=None): 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): class FutureRecordMetadata(Future):