Este é um problema conhecido com aipo. Ela decorre de um problema introduzido na dependência de bilhar. Uma solução alternativa é definir manualmente o
_config
atributo para o processo atual. Obrigado ao usuário @martinth pela solução abaixo. 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'}
O
worker_process_init
hook executará o código na inicialização do processo de trabalho. Nós simplesmente verificamos se _config
existe e defina-o se não existir.