(self)
| 478 | raise OperationFailure(e) |
| 479 | |
| 480 | def delete_all_error_jobs(self): |
| 481 | return self.delete_all(cond={"state": JOB_STATE_ERROR}) |
| 482 | |
| 483 | def reserve(self, host_id, cond=None, exp_key=None): |
| 484 | now = coarse_utcnow() |
nothing calls this directly
no test coverage detected