summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorDana Powers <dana.powers@rd.io>2016-01-23 16:58:56 -0800
committerDana Powers <dana.powers@rd.io>2016-01-23 16:59:11 -0800
commit0c395bd96a8a620299ee10584f664cee12f18615 (patch)
tree2540172af53b83d144b473486dc9b8d3ad67fc6c
parent962d8c08053e72ae5118ed57ecb6f5c94ac97708 (diff)
downloadkafka-python-0c395bd96a8a620299ee10584f664cee12f18615.tar.gz
Pylint ignores to fix weird 2.7 error in new pylint version
-rw-r--r--kafka/conn.py3
1 files changed, 3 insertions, 0 deletions
diff --git a/kafka/conn.py b/kafka/conn.py
index 0c8d002..5b54c85 100644
--- a/kafka/conn.py
+++ b/kafka/conn.py
@@ -417,6 +417,7 @@ class KafkaConnection(local):
while bytes_left:
try:
+ # pylint: disable-msg=no-member
data = self._sock.recv(min(bytes_left, 4096))
# Receiving empty string from recv signals
@@ -462,6 +463,7 @@ class KafkaConnection(local):
self.reinit()
try:
+ # pylint: disable-msg=no-member
self._sock.sendall(payload)
except socket.error:
log.exception('Unable to send payload to Kafka')
@@ -517,6 +519,7 @@ class KafkaConnection(local):
# But expect an error if the socket has already been
# closed by the server
try:
+ # pylint: disable-msg=no-member
self._sock.shutdown(socket.SHUT_RDWR)
except socket.error:
pass