Я подключился к своему удаленному кластеру через клиента, теперь я пытаюсь использовать Dask-ml
from sklearn.ensemble import RandomForestClassifier
from sklearn.externals import joblib
#import dask_ml.joblib
clf = RandomForestClassifier(n_estimators=200, n_jobs=-1)
with joblib.parallel_backend('dask', scatter = [X,y]):
clf.fit(X,y)
Ошибка 1) dask_ml.joblib отсутствует - я получаю модуль, который не существует ошибка
ошибка 2) если я удаляю этот импорт, я получаю сообщение о закрытии потокового соединения
Не вижу никакой хорошей документации по этому вопросу. Любые идеи о том, как заставить Dask-ml работать с удаленным кластером?