(self, job)
| 71 | return False |
| 72 | |
| 73 | def job_running(self, job): |
| 74 | future = self.get_task(job) |
| 75 | return future and future.status in ( |
| 76 | "PENDING", |
| 77 | "RECEIVED", |
| 78 | "STARTED", |
| 79 | "RETRY", |
| 80 | "PROGRESS", |
| 81 | ) |
| 82 | |
| 83 | def make_job_fn(self, fn, progress, key=None): |
| 84 | return _make_job_fn(fn, self.handle, progress, key) |