我所做的框架代码是
from IPython import parallel
.....
rcAll = parallel.Client()
all_engines = rcAll[:]
lbvAll = rcAll.load_balanced_view()
....
for anInpt in allInpt:
lbvAll.apply(mputil.doAll, anInpt)
lbvAll.wait()
lbvAll.get_result()
....
for ijk in range(len(list(lbvAll.results.values()))):
out = list(lbvAll.results.values())[ijk]
ionS = out[0]
但是,所包含的只是导入错误消息。
这在以前有效,但在 IPython 2.1 和 2.2 之间肯定发生了一些变化。至少,这是我的猜测。