summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorDana Powers <dana.powers@gmail.com>2015-12-03 11:48:41 -0800
committerDana Powers <dana.powers@gmail.com>2015-12-03 11:48:41 -0800
commit63b0e6108a8261ad3acdfb4cb01d2830a2dfa069 (patch)
tree90390cac4773c5d29de8dda109b08447a4db9a15
parent3e28b42e6691b864b6f940034a4ccdce0b69d406 (diff)
parent16f61547787e9cb5be855ec1c4391b3b56765ab8 (diff)
downloadkafka-python-63b0e6108a8261ad3acdfb4cb01d2830a2dfa069.tar.gz
Merge pull request #481 from zackdever/pylint-1.5-changes
new pylint disables for pylint 1.5.1
-rw-r--r--kafka/consumer/kafka.py2
-rw-r--r--kafka/consumer/simple.py2
-rw-r--r--test/fixtures.py2
3 files changed, 3 insertions, 3 deletions
diff --git a/kafka/consumer/kafka.py b/kafka/consumer/kafka.py
index 2141101..21b2bf6 100644
--- a/kafka/consumer/kafka.py
+++ b/kafka/consumer/kafka.py
@@ -661,7 +661,7 @@ class KafkaConsumer(object):
# Otherwise we should re-raise the upstream exception
# b/c it typically includes additional data about
# the request that triggered it, and we do not want to drop that
- raise
+ raise # pylint: disable-msg=E0704
(offset, ) = self.get_partition_offsets(topic, partition,
request_time_ms, max_num_offsets=1)
diff --git a/kafka/consumer/simple.py b/kafka/consumer/simple.py
index aad229a..7c63246 100644
--- a/kafka/consumer/simple.py
+++ b/kafka/consumer/simple.py
@@ -166,7 +166,7 @@ class SimpleConsumer(Consumer):
# Otherwise we should re-raise the upstream exception
# b/c it typically includes additional data about
# the request that triggered it, and we do not want to drop that
- raise
+ raise # pylint: disable-msg=E0704
# send_offset_request
log.info('Resetting topic-partition offset to %s for %s:%d',
diff --git a/test/fixtures.py b/test/fixtures.py
index 164d0d7..0ae1c1e 100644
--- a/test/fixtures.py
+++ b/test/fixtures.py
@@ -8,7 +8,7 @@ import time
from six.moves import urllib
import uuid
-from six.moves.urllib.parse import urlparse # pylint: disable-msg=E0611
+from six.moves.urllib.parse import urlparse # pylint: disable-msg=E0611,F0401
from test.service import ExternalService, SpawnedService
from test.testutil import get_open_port