@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(), но при вызове происходит какая то задержка (для меня скорость критична).
  • Вопрос задан
  • 2867 просмотров
Пригласить эксперта
Ваш ответ на вопрос

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

Похожие вопросы
23 нояб. 2024, в 01:31
1000 руб./за проект
23 нояб. 2024, в 00:16
2000 руб./за проект
22 нояб. 2024, в 23:55
3000 руб./за проект