[解決済み】celery / rabbitmqで保留中のタスクを全て削除する。

質問

を知らなくても、保留中のタスクをすべて削除するにはどうすればよいのでしょうか？ task_id を使用することができますか？

解決方法は？

からの ドキュメント :

$ celery -A proj purge

または

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

(編集：現在の方法に更新しました。)