absolute skip

Author: martindurant

streamz/tests/test_kafka.py

@@ -18,7 +18,8 @@
 from distributed.utils_test import gen_cluster  # flake8: noqa
 
 KAFKA_FILE = 'kafka_2.11-1.0.0'
-LAUNCH_KAFKA = os.environ.get('STREAMZ_LAUNCH_KAFKA', '') == 'true'
+if os.environ.get('STREAMZ_LAUNCH_KAFKA', '') != 'true':
+    pytest.skip("Not doing flaky kafka tests")
 ck = pytest.importorskip('confluent_kafka')