Обработка ошибок в периодических задачах 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")