(self, reason, terminated, signum, expired)
| 455 | send_retry(self.task, request=self._context, einfo=None) |
| 456 | |
| 457 | def _announce_revoked(self, reason, terminated, signum, expired): |
| 458 | task_ready(self) |
| 459 | self.send_event('task-revoked', |
| 460 | terminated=terminated, signum=signum, expired=expired) |
| 461 | self.task.backend.mark_as_revoked( |
| 462 | self.id, reason, request=self._context, |
| 463 | store_result=self.store_errors, |
| 464 | ) |
| 465 | self.acknowledge() |
| 466 | self._already_revoked = True |
| 467 | send_revoked(self.task, request=self._context, |
| 468 | terminated=terminated, signum=signum, expired=expired) |
| 469 | |
| 470 | def revoked(self): |
| 471 | """If revoked, skip task and mark state.""" |
no test coverage detected