See `BaseCheckpointer.wait_until_finished` docstring for details.
(self)
| 1208 | ) |
| 1209 | |
| 1210 | def wait_until_finished(self): |
| 1211 | """See `BaseCheckpointer.wait_until_finished` docstring for details.""" |
| 1212 | self._storage.wait_until_finished() |
| 1213 | |
| 1214 | def _index_exists(self, ckpt_dir: str): |
| 1215 | ckpt_index = os.path.join(ckpt_dir, "index") |
no test coverage detected