Method run_live_tool_loop_for_node

python/src/workflow/executor.rs:1178–1540

(
        node_id: &str,
        node_name: &str,
        initial_output: &serde_json::Value,
        workflow: &graphbit_core::workflow::Workflow,
        llm_config: graphbit_core::llm::LlmConfig,
 

    }

    async fn run_live_tool_loop_for_node(
        node_id: &str,
        node_name: &str,
        initial_output: &serde_json::Value,
        workflow: &graphbit_core::workflow::Workflow,
        llm_config: graphbit_core::llm::LlmConfig,
        guardrail_enforcer: Option<Arc<Enforcer>>,
        event_tx: &tokio::sync::mpsc::Sender<TimedStreamEvent>,
        stream_mode: StreamMode,
    ) -> Result<
        (String, Vec<serde_json::Value>, Vec<String>, String),
        graphbit_core::errors::GraphBitError,
    > {
        use crate::workflow::node::execute_production_tool_calls;
        use graphbit_core::llm::{LlmMessage, LlmProvider, LlmTool, LlmToolCall};

        let response_obj = initial_output;
        let initial_tool_calls = response_obj
            .get("tool_calls")
            .and_then(|v| v.as_array())
            .cloned()
            .unwrap_or_default();
        let original_prompt = response_obj
            .get("original_prompt")
            .and_then(|v| v.as_str())
            .unwrap_or("");
        let initial_content = response_obj
            .get("content")
            .and_then(|v| v.as_str())
            .unwrap_or("")
            .to_string();

        let node = workflow
            .graph
            .get_nodes()
            .iter()
            .find(|(id, _)| id.to_string() == node_id)
            .map(|(_, node)| node.clone())
            .ok_or_else(|| {
                graphbit_core::errors::GraphBitError::workflow_execution(format!(
                    "Node '{node_id}' not found while running live tool loop",
                ))
            })?;

        let node_tools = Self::extract_node_tools(&node.config);
        let llm_tools: Vec<LlmTool> = Self::extract_llm_tools(&node.config);
        let max_iterations = Self::extract_max_iterations(&node.config, 10);

        let llm_provider =
            graphbit_core::llm::LlmProviderFactory::create_provider(llm_config.clone())
                .map(|provider_trait| LlmProvider::new(provider_trait, llm_config.clone()))
                .map_err(|e| {
                    graphbit_core::errors::GraphBitError::workflow_execution(format!(
                        "Failed to create LLM provider for live streaming loop: {e}",
                    ))
                })?;

        let mut messages: Vec<LlmMessage> = vec![LlmMessage::user(original_prompt)];