最近需要用pp模块跑一个并行代码,核心代码如下:
# 并行跑各个簇的Hmm
job_server = pp.Server()
# 20个簇文件文件名
clusters = os.listdir('dataset/clu_data/')
# 构建任务 函数名,参数, 调用的函数, 用到的模块
jobs = [job_server.submit(hmm_model, (cluster,), (), ('pandas','numpy', 'hmmlearn.hmm', 'matplotlib.pyplot','pyecharts.Style', 'pyecharts.GeoLines')) for cluster in clusters]
# 执行任务
for job in jobs:
job()
但是报以下错误,应该是这个模型导包时的问题,请问这个要怎么解决?
报错信息已经很明确了,你应该检查下所有的源码文件,确保
from __future__ import ****
放在Python文件导包的第一行