Сельдерей: выборочно очистка очереди от задач Python

Question

Иногда возникает ситуация, когда очередь сельдерея строится на случайных ненужных задачах, забивая сервер. Например. код запускает 20 000 заданий вместо 1.

Как можно проверить, какие задачи Python содержит очередь сельдерея, а затем выборочно избавиться от определенных задач?

Задачи определены и начали со стандартным Сельдереем декораторами (если это имеет значение):

@task() 
def update_foobar(foo, bar): 
    # Some heavy activon here 
    pass 

update_foobar.delay(foo, bar) 

Stack: Джанго + сельдерей + RabbitMQ.

Answer 1

Возможно, вы можете использовать Flower. Это монитор реального времени для сельдерея с приятным веб-интерфейсом. Я думаю, что вы можете закрыть задачи оттуда. В любом случае я постараюсь избежать ненужных задач в очереди.