Я хотел бы написать метод, чтобы отменить текущую задачу celery в приложении django, я пробовал несколько разных способов, и я считаю, что документация немного запутанна. Я просто ищу простой пример.завершить текущую задачу сельдерея
Если вы хотите, чтобы получить список задач, вы можете использовать
from celery.task.control import inspect
inspect().active()
Это дает список активных задач, которые обрабатываются. Там вы можете получить идентификатор задачи. После того, как вы получили идентификатор задачи, вы можете отменить его с помощью этого
from celery.task.control import revoke
revoke(task_id, terminate=True)
Вы можете написать функцию для автоматизации этого.
Нужно ли быть в python? – josephmisiti
@josephmisiti желательно :) – agarrow
Если вы знаете идентификатор задачи, вы можете его напрямую разорвать. – ChillarAnand