Method execute_with_session

core/src/agent/execution_mode.rs:49–105

Execute the agent loop for a prompt with session context Takes the conversation history, user prompt, and optional session ID. When session_id is provided, context providers can use it for session-specific context.

(
        &self,
        history: &[Message],
        prompt: &str,
        session_id: Option<&str>,
        event_tx: Option<mpsc::Sender<AgentEvent>>,
        cancel_token: Option<&tokio_util::sync

    /// Takes the conversation history, user prompt, and optional session ID.
    /// When session_id is provided, context providers can use it for session-specific context.
    pub async fn execute_with_session(
        &self,
        history: &[Message],
        prompt: &str,
        session_id: Option<&str>,
        event_tx: Option<mpsc::Sender<AgentEvent>>,
        cancel_token: Option<&tokio_util::sync::CancellationToken>,
    ) -> Result<AgentResult> {
        let default_token = tokio_util::sync::CancellationToken::new();
        let token = cancel_token.unwrap_or(&default_token);
        tracing::info!(
            a3s.session.id = session_id.unwrap_or("none"),
            a3s.agent.max_turns = self.config.max_tool_rounds,
            "a3s.agent.execute started"
        );

        let route = self.resolve_execution_route(prompt).await;
        let mut effective_prompt = route.effective_prompt.clone();
        let mut auto_tool_calls_count = 0;
        if !route.use_planning {
            if let Some(outcome) = self
                .maybe_apply_auto_delegation(&effective_prompt, session_id, &event_tx)
                .await?
            {
                effective_prompt = outcome.prompt;
                auto_tool_calls_count = outcome.tool_calls_count;
            }
        }

        let mut result = if route.use_planning {
            self.execute_with_planning(
                history,
                &effective_prompt,
                session_id,
                event_tx,
                route.pre_analysis,
            )
            .await
        } else {
            self.execute_loop(
                history,
                &effective_prompt,
                route.style,
                session_id,
                event_tx,
                token,
                true,
            )
            .await
        };
        if let Ok(result) = &mut result {
            result.tool_calls_count += auto_tool_calls_count;
        }

        self.record_execution_result(session_id, &result).await;
        result
    }