Return recorded runtime events for a run.
(&self, py: Python<'_>, run_id: String)
| 1823 | |
| 1824 | /// Return recorded runtime events for a run. |
| 1825 | fn run_events(&self, py: Python<'_>, run_id: String) -> PyResult<PyObject> { |
| 1826 | let session = self.inner.clone(); |
| 1827 | let events = py.allow_threads(move || get_runtime().block_on(session.run_events(&run_id))); |
| 1828 | let json = serde_json::to_string(&events) |
| 1829 | .map_err(|e| PyRuntimeError::new_err(format!("Failed to serialize run events: {e}")))?; |
| 1830 | json_string_to_py(py, &json) |
| 1831 | } |
| 1832 | |
| 1833 | /// Return the currently running operation, or None when idle. |
| 1834 | fn current_run(&self, py: Python<'_>) -> PyResult<PyObject> { |
no test coverage detected