(self, job)
| 84 | return _make_job_fn(fn, self.handle, progress, key) |
| 85 | |
| 86 | def get_task(self, job): |
| 87 | if job: |
| 88 | return self.handle.AsyncResult(job) |
| 89 | |
| 90 | return None |
| 91 | |
| 92 | def clear_cache_entry(self, key): |
| 93 | self.handle.backend.delete(key) |
no outgoing calls
no test coverage detected