work with distributed 1.16.1

2017-04-17 11:05:19 +02:00 · 2017-04-17 11:05:19 +02:00 · 1b939a6823
commit 1b939a6823
parent 5b22d1486a
1 changed files with 2 additions and 1 deletions
--- a/examples/dask_distributed.py
+++ b/examples/dask_distributed.py
@ -36,5 +36,6 @@ async def test(request, value):

 if __name__ == '__main__':
    # Distributed cluster should run somewhere else
-    with LocalCluster(scheduler_port=8786, processes=False) as cluster:
+    with LocalCluster(scheduler_port=8786, nanny=False, n_workers=2,
+                      threads_per_worker=1) as cluster:
        app.run(host="0.0.0.0", port=8000)