(
self,
step: int,
state: Union[NestedTensor, NestedTensorSpec],
*,
ckpt_dir: str,
validation: CheckpointValidationType = CheckpointValidationType.EXACT,
)
| 332 | raise NotImplementedError(type(self)) |
| 333 | |
| 334 | def restore_from_dir( |
| 335 | self, |
| 336 | step: int, |
| 337 | state: Union[NestedTensor, NestedTensorSpec], |
| 338 | *, |
| 339 | ckpt_dir: str, |
| 340 | validation: CheckpointValidationType = CheckpointValidationType.EXACT, |
| 341 | ) -> NestedTensor: |
| 342 | raise NotImplementedError(type(self)) |
| 343 | |
| 344 | def stop(self): |
| 345 | """Stops and disposes resources.""" |
no outgoing calls