python - Dask 分布式文件上传抛出 FileNotFound

Question

我有四个 Docker 容器、Flask、一个 Dask 调度程序和两个 Dask 工作人员。

我需要在从调度程序/客户端提交的工作人员中运行代码。为此，我upload_file按照此处所述使用。

我得到的错误是找不到该文件。这是在 Flask 中运行的代码：

dask_client = Client('127.0.0.1:8786') 
dask_client.upload_file('predict_worker.py')
dask_client.map (myFunc, 1)

我在 Flask 容器中遇到的错误：

 FileNotFoundError: [Errno 2] No such file or directory: 'predict_worker.py'

该文件predict_worker.py位于运行 Flask 代码的同一文件夹中。如何告诉 Dask 在哪里找到这个文件？

标签： pythondaskdask-distributed