Method delete_workflow_checkpoint

core/src/store/file_store.rs:571–583

(&self, workflow_id: &str)

    }

    async fn delete_workflow_checkpoint(&self, workflow_id: &str) -> Result<()> {
        let path = self.workflow_checkpoint_path(workflow_id);
        if path.exists() {
            fs::remove_file(&path).await.with_context(|| {
                format!(
                    "Failed to delete workflow checkpoint for {}: {}",
                    workflow_id,
                    path.display()
                )
            })?;
        }
        Ok(())
    }

    async fn health_check(&self) -> Result<()> {
        // Verify directory exists and is writable