Function sync_global_tools_to_workflow

python/src/workflow/node.rs:898–940

(py: Python<'_>)

/// Bridge function to sync tools from global registry to thread-local registry
#[pyfunction]
pub(crate) fn sync_global_tools_to_workflow(py: Python<'_>) -> PyResult<()> {
    use crate::tools::decorator::get_global_registry;

    // Get tools from the global registry
    let global_registry = get_global_registry();
    let global_guard = global_registry.lock().map_err(|e| {
        PyErr::new::<pyo3::exceptions::PyRuntimeError, _>(format!(
            "Failed to acquire global registry lock: {}",
            e
        ))
    })?;

    // Get the list of registered tools from the global registry
    let global_tools = global_guard.list_tools().map_err(|e| {
        PyErr::new::<pyo3::exceptions::PyRuntimeError, _>(format!(
            "Failed to list global tools: {}",
            e
        ))
    })?;

    // For each tool in the global registry, get the actual function and register it in thread-local
    TOOL_REGISTRY.with(|local_registry| {
        let mut local_registry = local_registry.borrow_mut();

        for tool_name in global_tools {
            // Create a placeholder function that delegates to the global registry
            let tool_placeholder = py.eval(
                c"lambda *args, **kwargs: 'Tool execution delegated to global registry'",
                None,
                None,
            )?;

            local_registry.insert(
                tool_name.clone(),
                tool_placeholder.into_pyobject(py)?.into_any().unbind(),
            );
        }

        Ok::<(), PyErr>(())
    })?;

    Ok(())
}

/// Execute a tool from the global registry
fn execute_tool_from_global_registry(