Я - ладья ie с использованием Dask, и я установил новую версию 2.12.0 на свой MacBook MacOS High Sierra 10.13.6. Когда я пытаюсь запустить распределенный режим с кодом ниже:
from dask.distributed import Client
c = Client()
я получаю следующее ошибка :
---------------------------------------------------------------------------
AttributeError Traceback (most recent call last)
<ipython-input-1-67101dbde0b6> in <module>()
1 from dask.distributed import Client
----> 2 c = Client()
~/anaconda3/lib/python3.6/site-packages/distributed/client.py in __init__(self, address, loop, timeout, set_as_default, scheduler_file, security, asynchronous, name, heartbeat_interval, **kwargs)
554 if set_as_default:
555 self._previous_get = _globals.get('get')
--> 556 dask.set_options(get=self.get)
557 self._previous_shuffle = _globals.get('shuffle')
558 dask.set_options(shuffle='tasks')
AttributeError: module 'dask' has no attribute 'set_options'
Кроме того, если я создаю экземпляр c = Client(set_as_default=False)
кластер, кажется, успешно поднимается, потому что я получаю информацию о соединении для панели мониторинга ( см. Это изображение ). Но когда я перемещаюсь по приборной панели, появляется следующая ошибка .
В соответствии с документацией удаление одного кластера машины кажется тривиальным, но я не знаю что может быть не так. Я был бы очень признателен, если бы кто-нибудь помог мне разобраться с этим инцидентом;)