Function wrap_py_tool_request_intercept_fn

crates/python/src/py_callable.rs:240–254

Wrap a Python callable `(str, Json) -> Json` for tool request intercepts.

(py_fn: Py<PyAny>)

/// Wrap a Python callable `(str, Json) -> Json` for tool request intercepts.
pub fn wrap_py_tool_request_intercept_fn(py_fn: Py<PyAny>) -> ToolInterceptFn {
    Arc::new(move |name: &str, args: Json| {
        Python::attach(|py| {
            let py_args = json_to_py(py, &args).map_err(|e| {
                FlowError::Internal(format!("tool callback json_to_py failed for '{name}': {e}"))
            })?;
            let result = py_fn.call1(py, (name, py_args)).map_err(|e| {
                FlowError::Internal(format!("Python tool callable failed for '{name}': {e}"))
            })?;
            py_to_json(result.bind(py)).map_err(|e| {
                FlowError::Internal(format!("tool callback py_to_json failed for '{name}': {e}"))
            })
        })
    })
}

/// Wrap a Python callable `(Json) -> Json` for tool execution intercepts.
/// Supports both sync and async Python callables. If the callable returns a