BokehWebInterface not working for Dask Distributed

I upgraded my Dask from version 0.14.3 to 0.15.0 and distributed it from 1.16.3 to 1.17.0. BokehWebInterface has been removed from this version. The home page can be loaded http: // localhost: 8787 , but I can’t access the tasks, status, workers (it tries to restart until all tasks are completed and then gives it cannot reach the error). All that was used for an 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() 
0
source share
1 answer

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

0
source

Source: https://habr.com/ru/post/1266886/


All Articles