или через django? как я понимаю просто если взять app = Celery('myproject') то этот app не будет отдавать ноды, не будет иметь связь с нодами celery и надо отдельно запускать celery что бы получить данные. так ?
у меня есть api , по вызову api создаётся задача и сразу выполняется celery если нет другой которая выполняется. и мне надо убить, иногда, задачу которая выполняется в данный момент через интерфейс .
я нашёл такое в доке, но не получается пока применить:(
>>> from celery.task.control import revoke
>>> revoke(task_id, terminate=True)
Можешь свой app для этого использовать app.controls.revoke(...) Но учти что там не все пулы подходят, только prefork и eventlet
а какой экземпляр классе передавать ?
Не понимаю тебя
Обсуждают сегодня