我正在尝试通过调度程序,工作程序和客户端来设置分布式计算当我尝试使用以下命令导入调度程序时:
from dask.distributed import scheduler
它引发导入错误:
ImportError: cannot import name 'scheduler'
已安装dask,并通过以下命令分发:
sudo python -m pip install dask distributed --upgrade
该怎么办?
dask's repo,看来您应该以这种方式导入它:
from dask.distributed import Scheduler
注意大写字母S。