Method execute_tools

python/src/tools/executor.rs:248–375

Execute a sequence of tool calls

(
        &self,
        tool_calls: &Bound<'_, PyList>,
        py: Python<'_>,
    )

    /// Execute a sequence of tool calls
    pub fn execute_tools(
        &self,
        tool_calls: &Bound<'_, PyList>,
        py: Python<'_>,
    ) -> PyResult<ToolResultCollection> {
        // Validate configuration first
        self.validate_config()?;

        let start_time = Instant::now();

        // Validate input
        if tool_calls.is_empty() {
            return Ok(ToolResultCollection::new());
        }

        // Reset execution context
        {
            let mut context = self.execution_context.lock().map_err(|e| {
                ToolExecutionError::ContextLockError(format!(
                    "Failed to acquire context lock: {}",
                    e
                ))
            })?;
            context.reset();
            context.start_execution();
        }

        if self.config.enable_logging {
            info!(
                "Starting tool execution sequence with {} tools",
                tool_calls.len()
            );
        }

        let mut results = ToolResultCollection::new();
        let mut execution_count = 0;

        for (index, tool_call_item) in tool_calls.iter().enumerate() {
            // Check execution limits
            if let Err(e) = self.check_execution_limits(execution_count, start_time) {
                if self.config.enable_logging {
                    warn!("{}", e);
                }
                break;
            }

            // Parse and validate tool call
            let tool_call = match self.parse_tool_call(&tool_call_item, py) {
                Ok(call) => call,
                Err(e) => {
                    let error_result = ToolResult::failure(
                        "unknown_tool".to_string(),
                        "invalid_params".to_string(),
                        format!("Failed to parse tool call: {}", e),
                        0,
                    );
                    results.add(error_result);