diff options
| author | Ivan Pouzyrevsky <sandello@yandex-team.ru> | 2013-06-02 12:29:25 +0400 |
|---|---|---|
| committer | David Arthur <mumrah@gmail.com> | 2013-06-07 21:20:55 -0400 |
| commit | 2bd2dbcc9b141b76a91e6a4d92110e6ecc8bb3df (patch) | |
| tree | 28f0d64c020452966c7fed0937b3a54d1e92065b /kafka/codec.py | |
| parent | d7178e188e9ce82bef702e38ef4a0eaac49cd2e4 (diff) | |
| download | kafka-python-2bd2dbcc9b141b76a91e6a4d92110e6ecc8bb3df.tar.gz | |
Split fixtures out to a separate file
Diffstat (limited to 'kafka/codec.py')
| -rw-r--r-- | kafka/codec.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/kafka/codec.py b/kafka/codec.py index 35102ca..eb5d03c 100644 --- a/kafka/codec.py +++ b/kafka/codec.py @@ -12,7 +12,7 @@ def has_gzip(): return True -def _has_snappy(): +def has_snappy(): return _has_snappy @@ -38,11 +38,11 @@ def gzip_decode(payload): def snappy_encode(payload): if not _has_snappy: - raise NotImplementedError("Snappy codec not available") + raise NotImplementedError("Snappy codec is not available") return snappy.compress(payload) def snappy_decode(payload): if not _has_snappy: - raise NotImplementedError("Snappy codec not available") + raise NotImplementedError("Snappy codec is not available") return snappy.decompress(payload) |