Handler called if the task was successfully processed.
(self, failed__retval__runtime, **kwargs)
| 548 | self.acknowledge() |
| 549 | |
| 550 | def on_success(self, failed__retval__runtime, **kwargs): |
| 551 | """Handler called if the task was successfully processed.""" |
| 552 | failed, retval, runtime = failed__retval__runtime |
| 553 | if failed: |
| 554 | exc = retval.exception |
| 555 | if isinstance(exc, ExceptionWithTraceback): |
| 556 | exc = exc.exc |
| 557 | if isinstance(exc, (SystemExit, KeyboardInterrupt)): |
| 558 | raise exc |
| 559 | return self.on_failure(retval, return_ok=True) |
| 560 | task_ready(self, successful=True) |
| 561 | |
| 562 | if self.task.acks_late: |
| 563 | self.acknowledge() |
| 564 | |
| 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.""" |
nothing calls this directly
no test coverage detected