Function _run_sync_agent

src/tool_system/tools/agent.py:379–430

Run an agent synchronously and return the result.

(
        *,
        run_params: RunAgentParams,
        agent_id: str,
        start_time: float,
        prompt: str,
        agent_type: str,
    )

            )

    def _run_sync_agent(
        *,
        run_params: RunAgentParams,
        agent_id: str,
        start_time: float,
        prompt: str,
        agent_type: str,
    ) -> ToolResult:
        """Run an agent synchronously and return the result."""
        from ..protocol import ToolResult as TR
        from src.types.messages import Message

        agent_messages: list[Message] = []

        try:
            loop = asyncio.get_event_loop()
            if loop.is_running():
                # We're inside an async context — use a nested run
                import concurrent.futures
                with concurrent.futures.ThreadPoolExecutor(max_workers=1) as pool:
                    future = pool.submit(_sync_collect_agent_messages, run_params)
                    agent_messages = future.result()
            else:
                agent_messages = loop.run_until_complete(
                    _collect_agent_messages(run_params)
                )
        except RuntimeError:
            # No event loop — create one
            agent_messages = asyncio.run(
                _collect_agent_messages(run_params)
            )

        # Finalize result
        metadata = {
            "start_time": start_time,
            "agent_type": agent_type,
        }
        result = finalize_agent_tool(agent_messages, agent_id, metadata)

        return TR(
            name=AGENT_TOOL_NAME,
            output={
                "status": "completed",
                "prompt": prompt,
                "agent_id": result.agent_id,
                "agent_type": result.agent_type,
                "content": result.content,
                "total_duration_ms": result.total_duration_ms,
                "total_tokens": result.total_tokens,
                "total_tool_use_count": result.total_tool_use_count,
            },
        )

    def _launch_async_agent(
        *,