私は djcelery 開発に不慣れです。Web インターフェイスのボタンからワーカーをシャットダウンしたいと考えています。そのため、tasks.py でボタンがクリックされたときに次のタスクを呼び出しています。
result = broadcast('shutdown', destination=[worker.hostname])
ワーカーがアクティブなタスクである場合、すぐにシャットダウンされず、タスクの実行が完了するとダウンします。ただし、タスクの状態は常に「STARTED」です。ワーカーを再起動すると、タスクが再び取得されて実行されます。すでに実行されているため、タスクの状態を更新できる方法はありますか? CELERY_ACKS_LATE を True に設定しています。
更新: 私が使用しているセロリのバージョンは 3.0.9 (Chiastic Slide) で、Rabbitmq をブローカーとして使用しています。