Я обновил свой 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()
