fix last few skips

tests/pykafka/test_producer.py

@@ -182,9 +182,10 @@ def test_async_produce_queue_full(self):
         while consumer.consume() is not None:
             time.sleep(.05)
 
-    @pytest.mark.skipif(RDKAFKA, reason="rdkafka uses different lingering mechanism")
     def test_async_produce_lingers(self):
         """Ensure that the context manager waits for linger_ms milliseconds"""
+        if self.USE_RDKAFKA:
+            pytest.skip("rdkafka uses different lingering mechanism")
         linger = 3
         consumer = self._get_consumer()
         with self._get_producer(linger_ms=linger * 1000) as producer:

tests/pykafka/utils/test_compression.py

@@ -32,9 +32,9 @@ def test_snappy_xerial(self):
         decoded = compression.decode_snappy(encoded)
         self.assertEqual(self.text, decoded)
 
-    @pytest.mark.skipif(platform.python_implementation() == "PyPy",
-                        reason="PyPy fails to compress large messages with Snappy")
     def test_snappy_large_payload(self):
+        if platform.python_implementation() == "PyPy":
+            pytest.skip("PyPy fails to compress large messages with Snappy")
         payload = b''.join([uuid4().bytes for i in range(10)])
         c = compression.encode_snappy(payload)
         self.assertEqual(compression.decode_snappy(c), payload)
@@ -46,9 +46,9 @@ def test_lz4(self):
         decoded = compression.decode_lz4(encoded)
         self.assertEqual(self.text, decoded)
 
-    @pytest.mark.skipif(platform.python_implementation() == "PyPy",
-                        reason="lz4f is currently unsupported with PyPy")
     def test_lz4f(self):
+        if platform.python_implementation() == "PyPy":
+            pytest.skip("lz4f is currently unsupported with PyPy")
         encoded = lz4f.compressFrame(self.text)
         self.assertNotEqual(self.text, encoded)