diff options
| author | Dana Powers <dana.powers@rd.io> | 2016-01-03 16:09:52 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2016-01-03 16:09:52 -0800 |
| commit | 71af307f4e350a0e3ef21a6c986ebebb6717dc15 (patch) | |
| tree | 515b1f1f6109a1d87333b4ce22a920fb52984e84 | |
| parent | 16c56235d2fa1a9b63a38bd01aeb28be9aaa2405 (diff) | |
| download | kafka-python-71af307f4e350a0e3ef21a6c986ebebb6717dc15.tar.gz | |
Disable pylint error on __iter__ (next is provided via six.Iterator)
| -rw-r--r-- | kafka/consumer/fetcher.py | 2 | ||||
| -rw-r--r-- | kafka/consumer/group.py | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/kafka/consumer/fetcher.py b/kafka/consumer/fetcher.py index 8f25561..1593018 100644 --- a/kafka/consumer/fetcher.py +++ b/kafka/consumer/fetcher.py @@ -377,7 +377,7 @@ class Fetcher(six.Iterator): # fetch multiple partitions in bulk when they are on the same broker self.init_fetches() - def __iter__(self): + def __iter__(self): # pylint: disable=non-iterator-returned return self def __next__(self): diff --git a/kafka/consumer/group.py b/kafka/consumer/group.py index fe94d86..0293b4c 100644 --- a/kafka/consumer/group.py +++ b/kafka/consumer/group.py @@ -634,7 +634,7 @@ class KafkaConsumer(six.Iterator): if time.time() > timeout: break - def __iter__(self): + def __iter__(self): # pylint: disable=non-iterator-returned return self def __next__(self): |