Estou a usarSalsã para gerenciar tarefas assíncronas. Ocasionalmente, no entanto, o processo de aipo é interrompido, o que faz com que nenhuma das tarefas seja executada. Gostaria de poder verificar o status do aipo e garantir que tudo esteja funcionando bem e, se detectar algum problema, exibirá uma mensagem de erro para o usuário. Na documentação do Trabalhador do Aipo, parece que eu posso usar ping ouinspeciona para isso, mas o ping parece hacky e não está claro exatamente como a inspeção deve ser usada (se inspect (). registration () estiver vazia?).

Qualquer orientação sobre isso seria apreciada. Basicamente, o que estou procurando é um método assim:

def celery_is_alive():
    from celery.task.control import inspect
    return bool(inspect().registered()) # is this right??

EDIT: Nem parece que o registrado () está disponível no aipo 2.3.3 (embora os documentos 2.1 o listem). Talvez o ping seja a resposta cert

EDIT: Ping também parece não fazer o que eu pensei que faria, então ainda não tenho certeza da resposta aqu