Работник Dask не смог десериализовать задачу
Я добавил новый узел в кластер dask и установил все зависимости с помощью conda. Установка схожа с точки зрения пакета и версии на всех узлах dask.
Однако задача на новом узле завершается с ошибкой ниже:
ModuleNotFoundError: No module named 'parquet_thrift'
[работник.... ]: распределенный.работник - ВНИМАНИЕ - Не удалось десериализовать задачу
Все остальные узлы работают нормально. К вашему сведению: на всех узлах установлен быстрый паркет.
Пожалуйста, дайте мне знать, если я что-то упустил.