Redis
 sql >> Base de Dados >  >> NoSQL >> Redis

Usar o pool de multiprocessamento da tarefa de aipo gera exceção


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.