(&self, run_id: &str)
| 483 | } |
| 484 | |
| 485 | async fn delete_loop_checkpoint(&self, run_id: &str) -> Result<()> { |
| 486 | let path = self.loop_checkpoint_path(run_id); |
| 487 | if path.exists() { |
| 488 | fs::remove_file(&path).await.with_context(|| { |
| 489 | format!( |
| 490 | "Failed to delete loop checkpoint for run {}: {}", |
| 491 | run_id, |
| 492 | path.display() |
| 493 | ) |
| 494 | })?; |
| 495 | } |
| 496 | Ok(()) |
| 497 | } |
| 498 | |
| 499 | async fn save_workflow_checkpoint( |
| 500 | &self, |