BokehWebInterface不适用于Dask Distributed [英] BokehWebInterface not working for Dask Distributed

问题描述

我已将Dask从0.14.3版本更新到0.15.0，并从1.16.3版本发布到1.17.0。 BokehWebInterface已从此版本中删除。可以 http：// localhost：8787 加载主页，但是我无法访问任务，状态，工作程序（它尝试重新加载，直到所有任务完成，然后给出无法到达错误）。一切都可以在早期版本上使用。

I have updated my Dask from version 0.14.3 to 0.15.0, and distributed from 1.16.3 to 1.17.0. BokehWebInterface has been removed from this version. The homepage can be loaded http://localhost:8787, but I can't access tasks, status, workers(It tries to reload until all task are finished and then gives can't reach error). Everything used to work on the earlier version.

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()

推荐答案

此问题已通过Bokeh的0.12.6版本解决。谢谢@MRocklin的投入。

The problem is fixed with 0.12.6 version of Bokeh. Thanks, @MRocklin for the inputs.

这篇关于BokehWebInterface不适用于Dask Distributed的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！