(self, epoch)
| 322 | return self._timed_task('checkpoint_partial_load', add_op) |
| 323 | |
| 324 | def check_db_exists(self, epoch): |
| 325 | logger.info('Check existence of %s' % |
| 326 | db_name(epoch, self._node_name, self._db_prefix)) |
| 327 | with Task() as task: |
| 328 | existence = ops.Const(False) |
| 329 | ops.DBExists( |
| 330 | [], |
| 331 | [existence], |
| 332 | db_name=db_name(epoch, self._node_name, self._db_prefix), |
| 333 | db_type=self._db_type, |
| 334 | absolute_path=True) |
| 335 | task.add_output(existence) |
| 336 | return task |
| 337 | |
| 338 | def report_checkpoint_stats(self, action_name): |
| 339 | """ |
no test coverage detected