Merge branch 'master' of https://github.com/chinmaychandak/streamz

Author: Chinmay Chandak

streamz/tests/test_dask.py

@@ -14,7 +14,7 @@
 from distributed.utils_test import gen_cluster, inc, cluster, loop, slowinc  # noqa: F401
 
 
-@gen_cluster(client=True, check_new_threads=False)
+@gen_cluster(client=True)
 def test_map(c, s, a, b):
     source = Stream(asynchronous=True)
     futures = scatter(source).map(inc)