Mark task as successfully executed.
(self, task_id, result,
request=None, store_result=True, state=states.SUCCESS)
| 178 | return self.store_result(task_id, meta, states.STARTED) |
| 179 | |
| 180 | def mark_as_done(self, task_id, result, |
| 181 | request=None, store_result=True, state=states.SUCCESS): |
| 182 | """Mark task as successfully executed.""" |
| 183 | if (store_result and not _is_request_ignore_result(request)): |
| 184 | self.store_result(task_id, result, state, request=request) |
| 185 | if request and request.chord: |
| 186 | self.on_chord_part_return(request, state, result) |
| 187 | |
| 188 | def mark_as_failure(self, task_id, exc, |
| 189 | traceback=None, request=None, |