from celery import Task
import logging

# 实例化myLogger
myLogger = logging.getLogger('log')


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)