Я нахожусь на dask 1.1.1 (последняя версия), и я запустил планировщик dask в командной строке с помощью этой команды:
$ dask-scheduler --port 9796 --bokeh-port 9797 --bokeh-prefix my_project
distributed.scheduler - INFO - -----------------------------------------------
distributed.scheduler - INFO - Clear task state
distributed.scheduler - INFO - Scheduler at: tcp://10.1.0.107:9796
distributed.scheduler - INFO - bokeh at: :9797
distributed.scheduler - INFO - Local Directory: /tmp/scheduler-pdnwslep
distributed.scheduler - INFO - -----------------------------------------------
distributed.scheduler - INFO - Register tcp://10.1.25.4:36310
distributed.scheduler - INFO - Starting worker compute stream, tcp://10.1.25.4:36310
distributed.core - INFO - Starting established connection
затем ... Я попытался запустить клиент дляподключитесь к планировщику, используя этот код:
from dask.distributed import Client
c = Client('10.1.0.107:9796', set_as_default=False)
, но при попытке сделать это я получаю сообщение об ошибке:
...
File "/root/anaconda3/lib/python3.7/site-packages/tornado/concurrent.py", line 238, in result
raise_exc_info(self._exc_info)
File "<string>", line 4, in raise_exc_info
tornado.gen.TimeoutError: Timeout
During handling of the above exception, another exception occurred:
...
File "/root/anaconda3/lib/python3.7/site-packages/distributed/comm/core.py", line 195, in _raise
raise IOError(msg)
OSError: Timed out trying to connect to 'tcp://10.1.0.107:9796' after 10 s: connect() didn't finish in time
Это было жестко задано в системе, которая работала в течение нескольких месяцевсейчас.Так что я просто пишу этот вопрос, чтобы убедиться, что я не делаю ничего плохого программно, верно?Я думаю, что это должно быть что-то не так с окружающей средой.Все выглядит правильно для вас?какие вещи могут остановить это за пределами dask и python?сертификаты?разные версии пакетов?мысли