Method load_loop_checkpoint

core/src/store/file_store.rs:468–483

(&self, run_id: &str)

    }

    async fn load_loop_checkpoint(&self, run_id: &str) -> Result<Option<LoopCheckpoint>> {
        let path = self.loop_checkpoint_path(run_id);
        if !path.exists() {
            return Ok(None);
        }
        let json = fs::read_to_string(&path)
            .await
            .with_context(|| format!("Failed to read loop checkpoint from {}", path.display()))?;
        let checkpoint: LoopCheckpoint = serde_json::from_str(&json)
            .with_context(|| format!("Failed to parse loop checkpoint from {}", path.display()))?;
        // Refuse to hand back a checkpoint written by a future, incompatible
        // schema version — its field semantics may differ (see the contract
        // on LoopCheckpoint::ensure_loadable).
        checkpoint.ensure_loadable()?;
        Ok(Some(checkpoint))
    }

    async fn delete_loop_checkpoint(&self, run_id: &str) -> Result<()> {
        let path = self.loop_checkpoint_path(run_id);