summaryrefslogtreecommitdiff
path: root/kafka/producer
diff options
context:
space:
mode:
authorDana Powers <dana.powers@rd.io>2016-01-01 22:59:55 -0800
committerDana Powers <dana.powers@rd.io>2016-01-01 23:00:13 -0800
commitb6e9b7f74dd1f48b5331600fc4c80406c35c6993 (patch)
tree9dd95a6791aa09174fccbf44d3c0cd20d2126305 /kafka/producer
parenteab50649297033a7c0883fb30b7f6e0ade77b603 (diff)
downloadkafka-python-b6e9b7f74dd1f48b5331600fc4c80406c35c6993.tar.gz
Disable pylint errors for py2/py3 compatibility workarounds
Diffstat (limited to 'kafka/producer')
-rw-r--r--kafka/producer/base.py7
1 files changed, 4 insertions, 3 deletions
diff --git a/kafka/producer/base.py b/kafka/producer/base.py
index d733172..4f5edbc 100644
--- a/kafka/producer/base.py
+++ b/kafka/producer/base.py
@@ -5,9 +5,9 @@ import logging
import time
try:
- from queue import Empty, Full, Queue
+ from queue import Empty, Full, Queue # pylint: disable=import-error
except ImportError:
- from Queue import Empty, Full, Queue
+ from Queue import Empty, Full, Queue # pylint: disable=import-error
from collections import defaultdict
from threading import Thread, Event
@@ -444,7 +444,8 @@ class Producer(object):
# ValueError on list.remove() if the exithandler no longer exists
# but that is fine here
try:
- atexit._exithandlers.remove((self._cleanup_func, (self,), {}))
+ atexit._exithandlers.remove( # pylint: disable=no-member
+ (self._cleanup_func, (self,), {}))
except ValueError:
pass