(self, job: SubmittedJob)
| 105 | return len(failed_jobs) == 0 |
| 106 | |
| 107 | def get_failed_tasks(self, job: SubmittedJob) -> Dict[TaskId, FailedTaskContext]: |
| 108 | result = self.connection.get_failed_tasks([job.id]) |
| 109 | return result[job.id] |
| 110 | |
| 111 | def forget(self, job: HasJobId): |
| 112 | """ |
no outgoing calls