ModuleNotFound
尝试导入本地模块时,工作程序 Pod 出现错误。我可以在主节点上毫无问题地导入。主人和工人使用完全相同的图像。
图像上的工作目录组织如下:
WorkDIR/
TheNotebook.ipynb
MyModule/
__init__.py
myModule.py
笔记本类似于
from MyModule import workerFunc
fut = daskClient.submit(workerFunc,*workerArgs);
fut.result()
产生:
/usr/local/lib/python3.6/site-packages/distributed/client.py in result(self, timeout)
222 if self.status == "error":
223 typ, exc, tb = result
--> 224 raise exc.with_traceback(tb)
225 elif self.status == "cancelled":
226 raise result
/usr/local/lib/python3.6/site-packages/distributed/protocol/pickle.py in loads()
57 def loads(x):
58 try:
---> 59 return pickle.loads(x)
60 except Exception:
61 logger.info("Failed to deserialize %s", x[:10000], exc_info=True)
ModuleNotFoundError: No module named MyModule
我没有在 docker 映像中“安装”模块,我只是假设 worker pod 上的工作目录与 docker 映像上的 WORKDIR 相同。这是不正确的吗?我需要创建setup.py
并安装MyModule
吗?
谢谢!