MCPcopy
hub / github.com/celery/celery / on_failure

Method on_failure

celery/app/task.py:1100–1114  ·  view source on GitHub ↗

Error handler. This is run by the worker when the task fails. Arguments: exc (Exception): The exception raised by the task. task_id (str): Unique id of the failed task. args (Tuple): Original arguments for the task that failed. kwargs

(self, exc, task_id, args, kwargs, einfo)

Source from the content-addressed store, hash-verified

1098 """
1099
1100 def on_failure(self, exc, task_id, args, kwargs, einfo):
1101 """Error handler.
1102
1103 This is run by the worker when the task fails.
1104
1105 Arguments:
1106 exc (Exception): The exception raised by the task.
1107 task_id (str): Unique id of the failed task.
1108 args (Tuple): Original arguments for the task that failed.
1109 kwargs (Dict): Original keyword arguments for the task that failed.
1110 einfo (~billiard.einfo.ExceptionInfo): Exception information.
1111
1112 Returns:
1113 None: The return value of this handler is ignored.
1114 """
1115
1116 def after_return(self, status, retval, task_id, args, kwargs, einfo):
1117 """Handler called after the task returns.

Calls

no outgoing calls