Store return value and state of an executed task.
(self, task_id, result, state,
traceback=None, request=None, **kwargs)
| 212 | self._lock.release() |
| 213 | |
| 214 | def _store_result(self, task_id, result, state, |
| 215 | traceback=None, request=None, **kwargs): |
| 216 | """Store return value and state of an executed task.""" |
| 217 | self._get_connection(write=True) |
| 218 | |
| 219 | self._session.execute(self._write_stmt, ( |
| 220 | task_id, |
| 221 | state, |
| 222 | buf_t(self.encode(result)), |
| 223 | self.app.now(), |
| 224 | buf_t(self.encode(traceback)), |
| 225 | buf_t(self.encode(self.current_task_children(request))) |
| 226 | )) |
| 227 | |
| 228 | def as_uri(self, include_password=True): |
| 229 | return 'cassandra://' |