(self, emit_retry=True)
| 437 | obj.terminate(signal) |
| 438 | |
| 439 | def _announce_cancelled(self, emit_retry=True): |
| 440 | task_ready(self) |
| 441 | self.send_event('task-cancelled') |
| 442 | |
| 443 | if emit_retry: |
| 444 | reason = 'cancelled by Celery' |
| 445 | exc = Retry(message=reason) |
| 446 | self.task.backend.mark_as_retry(self.id, |
| 447 | exc, |
| 448 | request=self._context) |
| 449 | |
| 450 | self.task.on_retry(exc, self.id, self.args, self.kwargs, None) |
| 451 | |
| 452 | self._already_cancelled = True |
| 453 | |
| 454 | if emit_retry: |
| 455 | send_retry(self.task, request=self._context, einfo=None) |
| 456 | |
| 457 | def _announce_revoked(self, reason, terminated, signum, expired): |
| 458 | task_ready(self) |
no test coverage detected