(&self, checkpoint_run_id: String)
| 3246 | /// when no checkpoint exists for `checkpointRunId`. |
| 3247 | #[napi] |
| 3248 | pub async fn resume_run(&self, checkpoint_run_id: String) -> napi::Result<AgentResult> { |
| 3249 | let session = self.inner.clone(); |
| 3250 | let result = get_runtime() |
| 3251 | .spawn(async move { session.resume_run(&checkpoint_run_id).await }) |
| 3252 | .await |
| 3253 | .map_err(|e| napi::Error::from_reason(format!("Task join error: {e}")))? |
| 3254 | .map_err(|e| napi::Error::from_reason(format!("{e}")))?; |
| 3255 | Ok(AgentResult::from(result)) |
| 3256 | } |
| 3257 | |
| 3258 | /// Run `specs` as a fan-out of agent steps, bounded by the session's |
| 3259 | /// configured parallelism, and resolve with each step's outcome in input |
nothing calls this directly
no test coverage detected