Method run

src/agent/deep_agent/runner.py:175–260

Run the deep-agents loop for *question*. Args: question: Natural-language question to answer. Returns: :class:`AgentResult` with the final answer and full trajectory.

(self, question: str)

        return _build_chat_model(self._model_id)

    async def run(self, question: str) -> AgentResult:
        """Run the deep-agents loop for *question*.

        Args:
            question: Natural-language question to answer.

        Returns:
            :class:`AgentResult` with the final answer and full trajectory.
        """
        with agent_run_span(
            "deep-agent", model=self._model_id, question=question
        ) as span:
            run_started = time.perf_counter()
            started_at = _dt.datetime.now(_dt.UTC).isoformat()
            from deepagents import create_deep_agent
            from langchain_mcp_adapters.client import MultiServerMCPClient

            connections = _build_mcp_connections(self._server_paths)
            client = MultiServerMCPClient(connections) if connections else None
            tools = await client.get_tools() if client is not None else []

            agent = create_deep_agent(
                model=self._chat_model,
                tools=tools,
                system_prompt=AGENT_SYSTEM_PROMPT,
            )

            _log.info(
                "DeepAgentRunner: starting query (model=%s, tools=%d)",
                self._model_id,
                len(tools),
            )

            state = await agent.ainvoke(
                {"messages": [{"role": "user", "content": question}]},
                config={"recursion_limit": self._recursion_limit},
            )

            messages = state.get("messages", []) if isinstance(state, dict) else []
            trajectory = _build_trajectory(messages)
            trajectory.started_at = started_at

            answer = ""
            for msg in reversed(messages):
                if isinstance(msg, AIMessage):
                    if isinstance(msg.content, str) and msg.content.strip():
                        answer = msg.content
                        break
                    if isinstance(msg.content, list):
                        parts = [
                            p.get("text", "")
                            for p in msg.content
                            if isinstance(p, dict) and p.get("type") == "text"
                        ]
                        joined = "".join(parts).strip()
                        if joined:
                            answer = joined
                            break