Fix import

galipremsagar · web-flow · commit 59f0f987f39a · 2021-06-15T13:48:34.000-05:00
diff --git a/streamz/dask.py b/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
