Handler called if the task should be retried.
(self, exc_info)
| 565 | self.send_event('task-succeeded', result=retval, runtime=runtime) |
| 566 | |
| 567 | def on_retry(self, exc_info): |
| 568 | """Handler called if the task should be retried.""" |
| 569 | if self.task.acks_late: |
| 570 | self.acknowledge() |
| 571 | |
| 572 | self.send_event('task-retried', |
| 573 | exception=safe_repr(exc_info.exception.exc), |
| 574 | traceback=safe_str(exc_info.traceback)) |
| 575 | |
| 576 | def on_failure(self, exc_info, send_failed_event=True, return_ok=False): |
| 577 | """Handler called if the task raised an exception.""" |
no test coverage detected