, когда я пытаюсь добавить работника с адресом планировщика, выполнив следующую команду:
dask-worker tcp://10.142.0.3:8786
Мой планировщик выдает «add_worker () получил неожиданный аргумент ключевого слова« версии », как показано ниже»:
distributed.core - ERROR - add_worker() got an unexpected keyword argument 'versions'
Traceback (most recent call last):
File "/home/rsa-key-20180725/.local/lib/python3.6/site-packages/distributed/core.py", line 412, in handle_comm
result = handler(comm, **msg)
TypeError: add_worker() got an unexpected keyword argument 'versions'
Но рабочий не выдал никакой ошибки и выдал что-то вроде этого
distributed.nanny - INFO - Start Nanny at: 'tcp://10.142.0.6:45083'
distributed.worker - INFO - Start worker at: tcp://10.142.0.6:35275
distributed.worker - INFO - Listening to: tcp://10.142.0.6:35275
distributed.worker - INFO - Waiting to connect to: tcp://10.142.0.3:8786
distributed.worker - INFO - -------------------------------------------------
distributed.worker - INFO - Threads: 16
distributed.worker - INFO - Memory: 63.32 GB
distributed.worker - INFO - Local Directory: /home/rsa-key-20180725/dask-worker-space/worker-t9crpot3
distributed.worker - INFO - -------------------------------------------------
В чем проблема и что можно сделать? ... Заранее спасибо !!