diff options
| author | Mark Roberts <wizzat@gmail.com> | 2014-04-23 11:26:27 -0700 |
|---|---|---|
| committer | Mark Roberts <wizzat@gmail.com> | 2014-04-23 11:26:27 -0700 |
| commit | 8a1f2e6c3a73131d3a32ee4c0012628a6913d1cd (patch) | |
| tree | c9ac269074fe5da67d457ae755dedf6558f1617e /test/test_codec.py | |
| parent | 86e1ac7b96a41cf84e220fa25a11f138555d5c7e (diff) | |
| download | kafka-python-8a1f2e6c3a73131d3a32ee4c0012628a6913d1cd.tar.gz | |
Split out kafka version environments, default tox no longer runs any integration tests, make skipped integration also skip setupClass, implement rudimentary offset support in consumer.py
Diffstat (limited to 'test/test_codec.py')
| -rw-r--r-- | test/test_codec.py | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/test/test_codec.py b/test/test_codec.py index c311c52..40bd1b4 100644 --- a/test/test_codec.py +++ b/test/test_codec.py @@ -14,7 +14,7 @@ from kafka.common import ( LeaderUnavailableError, PartitionUnavailableError ) from kafka.codec import ( - has_gzip, has_snappy, gzip_encode, gzip_decode, + has_snappy, gzip_encode, gzip_decode, snappy_encode, snappy_decode ) from kafka.protocol import ( @@ -23,7 +23,6 @@ from kafka.protocol import ( from testutil import * class TestCodec(unittest.TestCase): - @unittest.skipUnless(has_gzip(), "Gzip not available") def test_gzip(self): for i in xrange(1000): s1 = random_string(100) |