diff --git a/streamz/dask.py b/streamz/dask.py
index 52b59afa..0dde7ab1 100644
--- 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