diff options
| author | Dana Powers <dana.powers@rd.io> | 2016-01-25 17:34:06 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2016-01-25 17:35:52 -0800 |
| commit | 650a27103cad82256f7d2be2853d628d187566c5 (patch) | |
| tree | 053aa57fb6b74c4aca5e0ff1bfbe20b753e97495 /kafka/codec.py | |
| parent | 0a74a9eec07f148ba3554ed70e4bbda901bbcb6b (diff) | |
| download | kafka-python-650a27103cad82256f7d2be2853d628d187566c5.tar.gz | |
Ignore pylint errors on buffer/memoryview
Diffstat (limited to 'kafka/codec.py')
| -rw-r--r-- | kafka/codec.py | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/kafka/codec.py b/kafka/codec.py index 5adb2e5..09075e1 100644 --- a/kafka/codec.py +++ b/kafka/codec.py @@ -102,8 +102,10 @@ def snappy_encode(payload, xerial_compatible=True, xerial_blocksize=32*1024): # Chunk through buffers to avoid creating intermediate slice copies if six.PY2: + # pylint: disable-msg=undefined-variable chunker = lambda payload, i, size: buffer(payload, i, size) else: + # pylint: disable-msg=undefined-variable chunker = lambda payload, i, size: memoryview(payload)[i:size+i].tobytes() for chunk in (chunker(payload, i, xerial_blocksize) |