(self, key, job_fn, args, context)
| 93 | self.handle.backend.delete(key) |
| 94 | |
| 95 | def call_job_fn(self, key, job_fn, args, context): |
| 96 | task = job_fn.delay(key, self._make_progress_key(key), args, context) |
| 97 | return task.task_id |
| 98 | |
| 99 | def get_progress(self, key): |
| 100 | progress_key = self._make_progress_key(key) |
no test coverage detected