(&self, run_id: &str)
| 148 | } |
| 149 | |
| 150 | async fn load_latest(&self, run_id: &str) -> Option<LoopCheckpoint> { |
| 151 | match self.inner.load_loop_checkpoint(run_id).await { |
| 152 | Ok(opt) => opt, |
| 153 | Err(e) => { |
| 154 | tracing::warn!( |
| 155 | run_id = %run_id, |
| 156 | error = %e, |
| 157 | "Loop checkpoint load failed" |
| 158 | ); |
| 159 | None |
| 160 | } |
| 161 | } |
| 162 | } |
| 163 | } |
| 164 | |
| 165 | #[cfg(test)] |
nothing calls this directly
no test coverage detected