BokehWebInterface 不适用于 Dask 分布式

Question

我已将我的 Dask 从版本 0.14.3 更新到 0.15.0，并从 1.16.3 分发到 1.17.0。 BokehWebInterface 已从此版本中删除。主页可以加载http://localhost:8787，但我无法访问任务、状态、工作人员（它会尝试重新加载，直到所有任务完成然后给出无法到达错误）。以前的版本都可以正常工作。

loop = IOLoop.current()
t = Thread(target=loop.start)
t.setDaemon(True)
t.start()
workers = []
services = {('http', HTTP_PORT): HTTPScheduler, ('bokeh', BOKEH_INTERNAL_PORT): BokehScheduler}
port = 8786
scheduler = Scheduler(loop=loop, services=services)
workers = []
bokeh_web = None
try:
    scheduler.start(port)
    # removed after updating the dask and ditributed
    bokeh_web = BokehWebInterface(http_port=HTTP_PORT, bokeh_port=BOKEH_PORT)
    # start workers
    for resource in resources:
         workers.append(Worker(scheduler.ip, port, **opts).start(0))
finally:
    for worker in workers:
        worker.stop()
    scheduler.stop()
    bokeh_web.close()

Answer 1

该问题已在 0.12.6 版本的 Bokeh 中得到修复。谢谢@MRocklin 的意见。