Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Use new LZ4 API #1757

Merged
merged 1 commit into from Feb 13, 2018
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Jump to
Jump to file
Failed to load files.
Diff view
Diff view
3 changes: 2 additions & 1 deletion distributed/protocol/compression.py
Expand Up @@ -58,9 +58,10 @@ def _fixed_snappy_decompress(data):

try:
# try using the new lz4 API
import lz4.block
lz4_compress = lz4.block.compress
lz4_decompress = lz4.block.decompress
except AttributeError as err:
except ImportError:
# fall back to old one
lz4_compress = lz4.LZ4_compress
lz4_decompress = lz4.LZ4_uncompress
Expand Down