(self, ckpt_dir: str)
| 1212 | self._storage.wait_until_finished() |
| 1213 | |
| 1214 | def _index_exists(self, ckpt_dir: str): |
| 1215 | ckpt_index = os.path.join(ckpt_dir, "index") |
| 1216 | return fs.exists(ckpt_index) |
| 1217 | |
| 1218 | def restore( |
| 1219 | self, |
no test coverage detected