タスクが終了した直後に、キュー内のすべてのタスクを削除するにはどうすればよいですか?
私はこのようなものが欲しいです（セロリ/ rabbitmqのすべての保留中のタスクを削除します）が、セロリ3.0用です。
ありがとう
編集：
セロリのドキュメントから: http://docs.celeryproject.org/en/latest/faq.html#how-do-i-purge-all-waiting-tasks
私のコードは次のようになります:
セロリから current_app をセロリとしてインポート
@task
def task_a():
celery.control.purge()
5 つのタスクを発行した場合、最初のタスクのみが実行されると予想していました。どういうわけか、私はそれをしません。
ありがとう