from celery import Task
from server.settings import myLogger


class CustomTask(Task):
    """
    自定义的任务回调
    """
    def on_failure(self, exc, task_id, args, kwargs, einfo):
        myLogger.error('{0!r} failed: {1!r}'.format(task_id, exc))
        return super().on_failure(exc, task_id, args, kwargs, einfo)