Переопределить dask scheduler_port - PullRequest
Новая
       6

Переопределить dask scheduler_port

0 голосов
/ 04 ноября 2018

Я безуспешно пробовал несколько портов: 8787 действительно занят обслуживанием rstudio. Я мог бы перенаправить rstudio, но разве не должна работать следующая работа? 

from distributed import Client, LocalCluster
cluster = LocalCluster( scheduler_port = 8785 , n_workers = 2 )

Ошибка: 

/home/ec2-user/anaconda3/lib/python3.6/site-packages/distributed/bokeh/core.py:56: UserWarning: 
Port 8787 is already in use. 
Perhaps you already have a cluster running?
Hosting the diagnostics dashboard on a random port instead.
  warnings.warn('\n' + msg)
tornado.application - ERROR - Multiple exceptions in yield list

... 

~/anaconda3/lib/python3.6/multiprocessing/forkserver.py in connect_to_new_process(self, fds)
     64             raise ValueError('too many fds')
     65         with socket.socket(socket.AF_UNIX) as client:
---> 66             client.connect(self._forkserver_address)
     67             parent_r, child_w = os.pipe()
     68             child_r, parent_w = os.pipe()

ConnectionRefusedError: [Errno 111] Connection refused

1 Ответ

0 голосов
/ 04 ноября 2018

Я думаю, вам нужно переопределить diagnostics_port вместо:

https://github.com/dask/distributed/blob/2ec428ae5652f7d068baeb18223fb8a04ab8804e/distributed/deploy/local.py#L45-L49

...