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)
| 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. |
no outgoing calls