Коллеги, подскажите как получить список тасков в 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(), но при вызове происходит какая то задержка (для меня скорость критична).