Есть 4 функции, 2 работающие, 1 объединяющая и 1 обязательная для Django (она у меня вроде как main)
Если запустить все без мультипроцессинга, то все работает как надо, с ним выдает ошибку:
TypeError: cannot serialize '_io.TextIOWrapper' object
Сначала я подумал что это из-за работы с файлами, пробовал убирать все связанное с чтением и записью файлов - не помогло
Сам код(работающие функции не выкладываю, там уйма строк, 1 подключается к внешнему api и выдергивает данные, вторая обрабатывает их и добавляет в бд ):
def make_all(self, cat):
products = self.connect(cat)
self.get_items(products)
with open('cat_complete.txt', 'a') as file:
file.write(str(cat)+'\n')
file.close()
def handle(self, *args, **options):
cat_list = []
cats = Category.objects.all().exclude(catId=0).distinct()
for i in cats:
cat_list.append(str(i.catId))
with Pool(5) as p:
p.map(self.make_all, cat_list)