Това е известен проблем с целината. Това произтича от проблем, въведен в зависимостта от билярд. Заобиколно решение е да зададете ръчно _config атрибут за текущия процес. Благодаря на потребителя @martinth за решението по-долу.
from celery.signals import worker_process_init
from multiprocessing import current_process
@worker_process_init.connect
def fix_multiprocessing(**kwargs):
try:
current_process()._config
except AttributeError:
current_process()._config = {'semprefix': '/mp'}
worker_process_init hook ще изпълни кода при инициализиране на работния процес. Просто проверяваме дали _config съществува и го задайте, ако не съществува.
