openstack/deb-python-kafka
Code Issues Proposed changes

Drop now-redundant ready() check in Fetcher._handle_offset_response

Browse Source
This commit is contained in:
Dana Powers
2016-03-14 00:10:50 -07:00
parent c7bbec07e9
commit ee7114cebb
1 changed files with 0 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
kafka/consumer/fetcher.py
View File

@@ -479,9 +479,6 @@ class Fetcher(six.Iterator):
# so create a separate future and attach a callback to update it # so create a separate future and attach a callback to update it
# based on response error codes # based on response error codes
future = Future() future = Future()
if not self._client.ready(node_id):
return future.failure(Errors.NodeNotReadyError(node_id))
_f = self._client.send(node_id, request) _f = self._client.send(node_id, request)
_f.add_callback(self._handle_offset_response, partition, future) _f.add_callback(self._handle_offset_response, partition, future)
_f.add_errback(lambda e: future.failure(e)) _f.add_errback(lambda e: future.failure(e))