как удалить задачу из сельдерея с помощью брокера redis?

Я добавляю неправильную task celery с броузером redis

но теперь я хочу удалить неправильную task и я не могу найти способ сделать это

Есть ли какие-то команды или некоторые api для этого?

Я знаю два способа сделать это:

1) Удалить очередь непосредственно от брокера. В вашем случае это Редис. Есть две команды, которые могут вам помочь: llen (найти правую очередь) и del (чтобы удалить его).

2) Начните работника сельдерея с параметрами –purge или –discard . Вот помощь:

 --purge, --discard Purges all waiting tasks before the daemon is started. **WARNING**: This is unrecoverable, and the tasks will be deleted from the messaging server. 

У меня просто была такая проблема для будущих читателей,

http://celery.readthedocs.org/en/latest/faq.html#i-ve-purged-messages-but-there-are-still-messages-left-in-the-queue

поэтому, чтобы правильно очистить очередь ожидающих задач, вы должны остановить всех рабочих , а затем очистить задачи, используя celery.control.purge ().

1. Чтобы правильно очистить очередь ожидающих задач, вы должны остановить всех рабочих ( http://celery.readthedocs.io/en/latest/faq.html#i-ve-purged-messages-but-there-are- still-messages-left-in-the-queue ):

2 … и затем очистить задачи из определенной очереди:

 $ cd <source_dir $ celery amqp queue.purge <queue name> 

3. Запустите работников снова