Deleting all pending tasks in celery / rabbitmq

Question

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

Answer 1

From the docs:

$ celery -A proj purge

or

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

(EDIT: Updated with current method.)