Search code examples
taskrabbitmqcelerycelery-task

Deleting all pending tasks in celery?


How can I delete all pending tasks without knowing the task_id for each task?


Solution

  • From the docs:

    $ celery -A proj purge
    

    or

    from proj.celery import app
    app.control.purge()
    

    (EDIT: Updated with current method.)