Att använda multiprocessing pool från selleri uppgift väcker undantag

Detta är ett känt problem med selleri. Det härrör från en fråga som introducerades i biljardberoendet. En lösning är att manuellt ställa in _config attribut för den aktuella processen. Tack till användaren @martinth för lösningen nedan.

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 kommer att exekvera koden vid initiering av arbetsprocessen. Vi kontrollerar helt enkelt om _config finns och ställ in den om den inte gör det.