openstack/deb-python-kafka
Code Issues Proposed changes

Fixup RequestTimeoutError -> RequestTimedOutError

Browse Source
This commit is contained in:
Dana Powers
2016-02-15 11:05:41 -08:00
parent 4d17ec257f
commit 6c213d62b6
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
kafka/client_async.py
View File

@@ -633,7 +633,7 @@ class KafkaClient(object):
# If the socket flush hack did not work (which should force the # If the socket flush hack did not work (which should force the
# connection to close and fail all pending requests), then we # connection to close and fail all pending requests), then we
# get a basic Request Timeout. Thisisn # get a basic Request Timeout. Thisisn
if isinstance(f.exception, Errors.RequestTimeoutError): if isinstance(f.exception, Errors.RequestTimedOutError):
pass pass
elif six.PY2: elif six.PY2:
assert isinstance(f.exception.args[0], socket.error) assert isinstance(f.exception.args[0], socket.error)

2
kafka/producer/base.py
View File

@@ -250,7 +250,7 @@ class Producer(object):
async_retry_backoff_ms (int, optional): milliseconds to backoff on async_retry_backoff_ms (int, optional): milliseconds to backoff on
failed messages, defaults to 100. failed messages, defaults to 100.
async_retry_on_timeouts (bool, optional): whether to retry on async_retry_on_timeouts (bool, optional): whether to retry on
RequestTimeoutError, defaults to True. RequestTimedOutError, defaults to True.
async_queue_maxsize (int, optional): limit to the size of the async_queue_maxsize (int, optional): limit to the size of the
internal message queue in number of messages (not size), defaults internal message queue in number of messages (not size), defaults
to 0 (no limit). to 0 (no limit).