deleting all pending tasks in celery

From the docs:

$ celeryctl purge

or

from celery.task.control import discard_all
discard_all()