Použití multiprocessingového fondu z úlohy celer vyvolá výjimku

Toto je známý problém s celerem. Vyplývá to z problému zavedeného v závislosti na kulečníku. Řešením je ruční nastavení _config atribut pro aktuální proces. Děkujeme uživateli @martinth za řešení níže.

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 spustí kód při inicializaci pracovního procesu. Jednoduše zkontrolujeme, zda _config existuje, a pokud neexistuje, nastavte jej.