last

Author: martindurant

streamz/tests/test_kafka.py

@@ -19,7 +19,7 @@
 
 KAFKA_FILE = 'kafka_2.11-1.0.0'
 if os.environ.get('STREAMZ_LAUNCH_KAFKA', '') != 'true':
-    pytest.skip("Not doing flaky kafka tests")
+    pytest.skip("Not doing flaky kafka tests", allow_module_level=True)
 ck = pytest.importorskip('confluent_kafka')