(self, key)
| 97 | return task.task_id |
| 98 | |
| 99 | def get_progress(self, key): |
| 100 | progress_key = self._make_progress_key(key) |
| 101 | progress_data = self.handle.backend.get(progress_key) |
| 102 | if progress_data: |
| 103 | self.handle.backend.delete(progress_key) |
| 104 | return json.loads(progress_data) |
| 105 | |
| 106 | return None |
| 107 | |
| 108 | def result_ready(self, key): |
| 109 | return self.handle.backend.get(key) is not None |
no test coverage detected