我已经将我的Dask从版本0.14.3更新到0.15.0,并从1.16.3发布到1.17.0。BokehWebInterface已从此版本中删除。主页可以加载http://localhost:8787,但我不能访问任务,状态,工作者(它试图重新加载,直到所有任务都完成,然后给出can't reach错误)。以前所有的东西都可以在早期版本上运行。
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()https://stackoverflow.com/questions/44508308
复制相似问题