summaryrefslogtreecommitdiff
path: root/kafka/codec.py
diff options
context:
space:
mode:
authorJeff Widman <jeff@jeffwidman.com>2018-10-22 01:24:50 -0700
committerJeff Widman <jeff@jeffwidman.com>2018-10-22 01:24:50 -0700
commitc6d86b25be338b78c79ec9a0f20a365e67e36537 (patch)
tree356b2b35146b83407717bf6d79d2997017b67ba0 /kafka/codec.py
parent08c77499a2e8bc79d6788d70ef96d77752ed6325 (diff)
downloadkafka-python-vendor-six-consistently.tar.gz
Vendor `six` consistentlyvendor-six-consistently
Use vendored `six`, and also `six.moves.range` rather than `xrange`
Diffstat (limited to 'kafka/codec.py')
-rw-r--r--kafka/codec.py4
1 files changed, 2 insertions, 2 deletions
diff --git a/kafka/codec.py b/kafka/codec.py
index 4d180dd..aa9fc82 100644
--- a/kafka/codec.py
+++ b/kafka/codec.py
@@ -6,7 +6,7 @@ import platform
import struct
from kafka.vendor import six
-from kafka.vendor.six.moves import xrange # pylint: disable=import-error
+from kafka.vendor.six.moves import range
_XERIAL_V1_HEADER = (-126, b'S', b'N', b'A', b'P', b'P', b'Y', 0, 1, 1)
_XERIAL_V1_FORMAT = 'bccccccBii'
@@ -150,7 +150,7 @@ def snappy_encode(payload, xerial_compatible=True, xerial_blocksize=32*1024):
chunker = lambda payload, i, size: memoryview(payload)[i:size+i].tobytes()
for chunk in (chunker(payload, i, xerial_blocksize)
- for i in xrange(0, len(payload), xerial_blocksize)):
+ for i in range(0, len(payload), xerial_blocksize)):
block = snappy.compress(chunk)
block_size = len(block)