Method load_workflow_checkpoint

core/src/store/file_store.rs:549–569

(
        &self,
        workflow_id: &str,
    )

    }

    async fn load_workflow_checkpoint(
        &self,
        workflow_id: &str,
    ) -> Result<Option<WorkflowCheckpoint>> {
        let path = self.workflow_checkpoint_path(workflow_id);
        if !path.exists() {
            return Ok(None);
        }
        let json = fs::read_to_string(&path).await.with_context(|| {
            format!("Failed to read workflow checkpoint from {}", path.display())
        })?;
        let checkpoint: WorkflowCheckpoint = serde_json::from_str(&json).with_context(|| {
            format!(
                "Failed to parse workflow checkpoint from {}",
                path.display()
            )
        })?;
        // Refuse a future, incompatible schema version (see ensure_loadable).
        checkpoint.ensure_loadable()?;
        Ok(Some(checkpoint))
    }

    async fn delete_workflow_checkpoint(&self, workflow_id: &str) -> Result<()> {
        let path = self.workflow_checkpoint_path(workflow_id);