(self, task_id, reason='',
request=None, store_result=True, state=states.REVOKED)
| 288 | ) |
| 289 | |
| 290 | def mark_as_revoked(self, task_id, reason='', |
| 291 | request=None, store_result=True, state=states.REVOKED): |
| 292 | exc = TaskRevokedError(reason) |
| 293 | if store_result: |
| 294 | self.store_result(task_id, exc, state, |
| 295 | traceback=None, request=request) |
| 296 | if request and request.chord: |
| 297 | self.on_chord_part_return(request, state, exc) |
| 298 | |
| 299 | def mark_as_retry(self, task_id, exc, traceback=None, |
| 300 | request=None, store_result=True, state=states.RETRY): |