Испытывает проблему с JobLib при использовании функции из класса - PullRequest
0 голосов
/ 06 ноября 2019

Вот структура, которая у меня есть в настоящее время и которая не работает:

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: не удалось удалить сериализацию задачи. Убедитесь, что аргументывсе функции можно отобрать. "

Что я делаю не так и есть ли решение? Большое спасибо заранее!

...