diff options
| author | Dana Powers <dana.powers@rd.io> | 2016-01-02 13:12:29 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2016-01-02 13:13:10 -0800 |
| commit | 976970f89acfdb3582feed613722158004b0ff3e (patch) | |
| tree | 173bb174506250816880ddf6ad1515cc0d10d054 /kafka/conn.py | |
| parent | 77350fe0ca8bd9440c978b07a670b7a4188abcbd (diff) | |
| download | kafka-python-976970f89acfdb3582feed613722158004b0ff3e.tar.gz | |
Fixup b6a2ad9: Fail with ConnectionErrors in BrokerConnection.send
Diffstat (limited to 'kafka/conn.py')
| -rw-r--r-- | kafka/conn.py | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/kafka/conn.py b/kafka/conn.py index a1767ef..0e02382 100644 --- a/kafka/conn.py +++ b/kafka/conn.py @@ -165,8 +165,9 @@ class BrokerConnection(object): self._sock.setblocking(False) except (AssertionError, socket.error) as e: log.exception("Error sending %s to %s", request, self) - self.close(error=Errors.ConnectionError(e)) - return future.failure(e) + error = Errors.ConnectionError(e) + self.close(error=error) + return future.failure(error) log.debug('%s Request %d: %s', self, correlation_id, request) if expect_response: |