Вот структура, которая у меня есть в настоящее время и которая не работает:
from A import Some_Class
from joblib import Parallel, delayed
global a
a = Some_Class()`
def f1():
res = a.Function(arg) # Function is a function in class "a"
def f2(v1,v2):
df['A'] = df.apply(f1,axis=1)
if __name__ == '__main__':
__spec__ = None
result = Parallel(n_jobs=-2,verbose=0)(delayed(f2)(v1,v2) for v2 in a_list)
Я получаю ошибку «BrokenProcessPool: не удалось удалить сериализацию задачи. Убедитесь, что аргументывсе функции можно отобрать. "
Что я делаю не так и есть ли решение? Большое спасибо заранее!