使用 Joblib 并获取"cannot unpack non-iterable function object"

Question

我是多处理的新手。以下代码正确地说明了我正在尝试执行的操作：

import pandas as pd
import multiprocessing
from joblib import Parallel, delayed
one = [True, False]
one_bla = pd.Series(one)
one_names = pd.Series(['Mr. Pea', 'Mrs. Pea'])
one_names = list(zip(one_names, one_names.index))
two = {}
def q():
for k, m in one_bla.items():
if one_bla.iloc[i] == True:
two[i] = v
num_cores = multiprocessing.cpu_count()
results = Parallel(n_jobs=num_cores)(delayed(q) for i, v in one_names)

它让我TypeError: cannot unpack non-iterable function object.有人可以看看我在哪里犯了错误吗？

Answer 1

问题是延迟(q(命令后缺少偏执。试试这个;

results = Parallel(n_jobs=num_cores)(delayed(q)() for i, v in one_names)