Celery: selectively clearing queue from Python tasks

Question

Sometimes I have a situation where Celery queue builds up on accidental unnecessary tasks, clogging down the server. E.g. the code shoots up 20 000 tasks instead of 1.

How one can inspect what Python tasks Celery queue contains and then get selectively rid of certain tasks?

Tasks are defined and started with the standard Celery decorators (if that matters):

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

update_foobar.delay(foo, bar)

Stack: Django + Celery + RabbitMQ.

Diego Navarro · Accepted Answer · 2014-02-26 14:33:55Z

2

+50

Maybe you can use Flower. It's a real time monitor for Celery with a nice web interface. I think you can shutdown tasks from there. Anyways I would try to avoid those queued unnecessary tasks.

answered Feb 26, 2014 at 14:33

Diego Navarro

9,7323 gold badges31 silver badges33 bronze badges

Sign up to request clarification or add additional context in comments.

1 Comment

Mikko Ohtamaa Over a year ago

I'll give you the bounty as it is about to expire, though I was more looking for a comnmand line solution, without needing to install an extra software.

Collectives™ on Stack Overflow

Celery: selectively clearing queue from Python tasks

1 Answer 1

1 Comment

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

1 Comment

Your Answer

Sign up or log in

Post as a guest

Related