Estoy usandoApi para gestionar tareas asincrónicas. Ocasionalmente, sin embargo, el proceso de apio se cae, lo que hace que ninguna de las tareas se ejecute. Me gustaría poder verificar el estado del apio y asegurarme de que todo funciona bien, y si detecto algún problema, mostraré un mensaje de error al usuario. De la documentación de Celery Worker parece que podría usarsilbid oinspecciona para esto, pero ping se siente hacky y no está claro exactamente cómo se debe utilizar la inspección (si inspeccionar (). registrado () está vacío?).

Cualquier orientación sobre esto sería apreciada. Básicamente, lo que estoy buscando es un método como este:

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

EDIT: Ni siquiera parece registrado () está disponible en el apio 2.3.3 (aunque los documentos 2.1 lo enumeran). Quizás ping es la respuesta correcta.

EDIT: Ping tampoco parece hacer lo que pensé que haría, así que todavía no estoy seguro de la respuesta aquí.