Merge pull request #423 from galipremsagar/patch-1

Fix  `apply` import from `dask`

Author: martindurant

streamz/dask.py

@@ -4,7 +4,7 @@
 
 from tornado import gen
 
-from dask.compatibility import apply
+from dask.utils import apply
 from distributed.client import default_client
 
 from .core import Stream