Brug af multiprocessing pool fra selleri opgave rejser undtagelse

Dette er et kendt problem med selleri. Det stammer fra et problem introduceret i billardafhængigheden. En løsning er at indstille _config manuelt attribut for den aktuelle proces. Tak til brugeren @martinth for løsningen nedenfor.

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 vil udføre koden ved initialisering af arbejdsprocessen. Vi tjekker simpelthen om _config findes, og indstil den, hvis den ikke gør det.