Resume a previously-checkpointed run on this session. Loads the latest loop checkpoint stored under ``checkpoint_run_id`` and replays the agent loop from that boundary. A new run id is allocated for the resumed work. Raises ``RuntimeError`` when no ``session_store`` is configured, or when no checkpoint exists for the given id.
(&self, py: Python<'_>, checkpoint_run_id: String)
| 1474 | /// Raises ``RuntimeError`` when no ``session_store`` is configured, |
| 1475 | /// or when no checkpoint exists for the given id. |
| 1476 | fn resume_run(&self, py: Python<'_>, checkpoint_run_id: String) -> PyResult<PyAgentResult> { |
| 1477 | let session = self.inner.clone(); |
| 1478 | let result = py |
| 1479 | .allow_threads(move || get_runtime().block_on(session.resume_run(&checkpoint_run_id))) |
| 1480 | .map_err(|e| PyRuntimeError::new_err(format!("{e}")))?; |
| 1481 | Ok(PyAgentResult::from(result)) |
| 1482 | } |
| 1483 | |
| 1484 | /// Run `specs` as a fan-out of agent steps and return each step's outcome |
| 1485 | /// (a dict) in input order. Each spec is a dict with snake_case keys: |
nothing calls this directly
no test coverage detected