@task_failure.connect
def task_failure_handler(sender=None, task_id=None, task=None, args=None, kwargs=None, retval=None, state=None, **kwds):
    try:
        logger.error(u"Celery task FAILED on task_id={task_id}, {args}".format(
            task_id=task_id, args=args))
    except __HOLE__:
        pass
dataset/ETHPy150Open Impactstory/total-impact-webapp/tasks.py/task_failure_handler