@m0ody
backend dev (python, django, postgresql, celery)

Как получить список зарегистрированных task'ов в celery?

Коллеги, подскажите как получить список тасков в celery. В конфиге прописано
CELERY_IMPORTS = ('common.background.tasks', 'st.background.tasks', )

Пробую так:
from celery import current_app

>>> current_app.tasks
{'celery.chain': <@task: celery.chain of app:0x370b250>, 'celery.chord': <@task: celery.chord of app:0x370b250>, 'celery.chunks': <@task: celery.chunks of app:0x370b250>, 'celery.chord_unlock': <@task: celery.chord_unlock of app:0x370b250>, 'celery.group': <@task: celery.group of app:0x370b250>, 'celery.backend_cleanup': <@task: celery.backend_cleanup of app:0x370b250>, 'celery.map': <@task: celery.map of app:0x370b250>, 'celery.starmap': <@task: celery.starmap of app:0x370b250>}

т.е. моих тасков нет.

Есть способ получить список тасков через control.inspect().registered_tasks(), но при вызове происходит какая то задержка (для меня скорость критична).
  • Вопрос задан
  • 2843 просмотра
Пригласить эксперта
Ваш ответ на вопрос

Войдите, чтобы написать ответ

Войти через центр авторизации
Похожие вопросы