diff options
| author | Dana Powers <dana.powers@gmail.com> | 2017-10-08 13:58:43 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2017-10-10 11:04:00 -0700 |
| commit | 8bffeb9e277692fb4e3450275e9c5e4a6af10c0b (patch) | |
| tree | 1b9ab408ee1151cb4de5fb28bd6de12ef3edc419 | |
| parent | 45063c3c4680226cdec73db9df999ba9f00d44fc (diff) | |
| download | kafka-python-8bffeb9e277692fb4e3450275e9c5e4a6af10c0b.tar.gz | |
Fixup pylint disable message
| -rw-r--r-- | kafka/conn.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/kafka/conn.py b/kafka/conn.py index e2d7707..a131413 100644 --- a/kafka/conn.py +++ b/kafka/conn.py @@ -445,9 +445,9 @@ class BrokerConnection(object): self._sasl_auth_future = future self._recv() if self._sasl_auth_future.failed(): - ex = self._sasl_auth_future.exception # pylint: disable-msg=raising-bad-type + ex = self._sasl_auth_future.exception if not isinstance(ex, Errors.ConnectionError): - raise ex + raise ex # pylint: disable-msg=raising-bad-type return self._sasl_auth_future.succeeded() def _handle_sasl_handshake_response(self, future, response): |