From 6c213d62b6ffb52decfb58b57eef41963e570244 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Mon, 15 Feb 2016 11:05:41 -0800 Subject: Fixup RequestTimeoutError -> RequestTimedOutError --- kafka/client_async.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'kafka/client_async.py') diff --git a/kafka/client_async.py b/kafka/client_async.py index 844d3b3..25ef29f 100644 --- a/kafka/client_async.py +++ b/kafka/client_async.py @@ -633,7 +633,7 @@ class KafkaClient(object): # If the socket flush hack did not work (which should force the # connection to close and fail all pending requests), then we # get a basic Request Timeout. Thisisn - if isinstance(f.exception, Errors.RequestTimeoutError): + if isinstance(f.exception, Errors.RequestTimedOutError): pass elif six.PY2: assert isinstance(f.exception.args[0], socket.error) -- cgit v1.2.1