Django-Celery定期的なタスクエラー処理

Question

定期的にバックグラウンドで実行される引数を取らないCeleryタスクがあります。

遭遇する特定のオブジェクトのエラーをトレースバックするには、on_failureを使用します。

何も引数をとらないので、値をargsに割り当てることができません。

タスクの実行中にオブジェクトとそのエラーが発生するのはどうすればよいですか？

Answer 1

は、私はあなたのコードスニペットを追加する場合、コードのこの作品は、

from celery.task import PeriodicTask 
class Task(PeriodicTask): 
    run_every = crontab(minute=0, hour=0) 
    def run(self, **kwargs): 
     # to do 
    def on_failure(self, exc, task_id, args, kwargs, einfo): 
     print("Failed")