当我运行一些代码时，为什么Dask仪表板不更新呢？

Question

我正试图重现达斯克仪表板的行为，如这段Youtube视频GqzcuGLCY中所示。我可以看到我的仪表板，但是当我运行计算时它不会更新。

我正在本地机器上运行所有的东西(Kubuntu18.04)。我用anaconda建立了我的环境，包括

• python 2.7.14
• 达斯克0.17.4
• 达斯克-核心0.17.4
• bokeh 1.0.4
• 龙卷风4.5.1

我从命令行设置了调度程序。

dask-scheduler
distributed.scheduler - INFO - -----------------------------------------------
distributed.scheduler - INFO - Clear task state
distributed.scheduler - INFO -   Scheduler at:  tcp://192.168.1.204:8786
distributed.scheduler - INFO -       bokeh at:                     :8787
distributed.scheduler - INFO - Local Directory:      /tmp/scheduler-bYQe2p
distributed.scheduler - INFO - -----------------------------------------------
distributed.scheduler - INFO - Register tcp://127.0.0.1:35007
distributed.scheduler - INFO - Starting worker compute stream, tcp://127.0.0.1:35007

...and也是个工人。

 dask-worker localhost:8786
distributed.nanny - INFO -         Start Nanny at: 'tcp://127.0.0.1:36345'
distributed.worker - INFO -       Start worker at:      tcp://127.0.0.1:44033
distributed.worker - INFO -          Listening to:      tcp://127.0.0.1:44033
distributed.worker - INFO -              bokeh at:             127.0.0.1:8789
distributed.worker - INFO -              nanny at:            127.0.0.1:36345
distributed.worker - INFO - Waiting to connect to:       tcp://localhost:8786
distributed.worker - INFO - -------------------------------------------------
distributed.worker - INFO -               Threads:                          4
distributed.worker - INFO -                Memory:                   16.70 GB
distributed.worker - INFO -       Local Directory: /home/fergal/orbital/repos/projects/safegraph/dask/dask-worker-space/worker-QjJ1ke
distributed.worker - INFO - -------------------------------------------------
distributed.worker - INFO -         Registered to:       tcp://localhost:8786
distributed.worker - INFO - -------------------------------------------------

那么我从视频中借用的代码是

from dask.distributed import Client
import dask.array as da

client = Client(processes=False)
print(client)

x = da.random.random((10000, 10000, 10), chunks=(1000,1000,5))
y = da.random.random((10000, 10000, 10), chunks=(1000,1000,5))
z = (da.arcsin(x) + da.arcsin(y)).sum(axis=(1,2))
z.visualize('eg.svg')
z.compute()

代码运行，并通过图形生成一个图形。bokeh服务器可在127.0.0.1:8787/status访问，并在右上角显示一个大的蓝色块，如视频的前几秒钟所示。但是当我运行我的代码时，网页不会更新以显示正在运行的计算，也不会在计算完成时显示任何结果。我希望能在视频中看到类似我在1:20左右看到的东西。

毫无疑问，我忽略了正确地设置一些东西，但是我在文档或堆栈溢出中找不到任何线索。那我做错什么了？

Answer 1

我找到了解决办法。

将dask更新为1.1.5，关闭dask-调度程序(和dask)。我猜我的问题是默认conda通道中的dask版本已经过时了。我从康达锻造下载了更新的版本。