Я настроил кластер dask.Я могу получить доступ к веб-панели инструментов, но когда я пытаюсь подключиться к планировщику:
from dask.distributed import Client
client = Client('192.168.0.10:8786')
, я получаю следующую ошибку:
tornado.application - ERROR - Exception in Future <Future cancelled> after timeout
Traceback (most recent call last):
File "/home/user/venv/lib/python3.5/site-packages/tornado/gen.py", line 970, in error_callback
future.result()
File "/usr/lib/python3.5/asyncio/futures.py", line 285, in result
raise CancelledError
concurrent.futures._base.CancelledError
Кроме того, когда я пытаюсьЧтобы выполнить некоторые задачи в кластере, все задачи вычисляются правильно, и результат выбирается, но в конце возникает вышеуказанная ошибка.
У вас есть идеи, как это исправить?Я думаю, что это проблема клиента, но где.Большое спасибо.