@@ -58,7 +58,7 @@ async def call_agent(self) -> str:
5858 self .append_message_and_log (message )
5959 if message .tool_calls :
6060 # Create tasks for all tool calls to run them in parallel
61- tool_tasks = []
61+ tool_tasks : List [ asyncio . Task [ tuple [ str , List [ TextContent ]]]] = []
6262 for tool_call in message .tool_calls :
6363 tool_call_id = tool_call .id
6464 tool_name = tool_call .function .name
@@ -70,7 +70,7 @@ async def call_agent(self) -> str:
7070 tool_tasks .append (task )
7171
7272 # Execute all tool calls in parallel
73- tool_results : List [ tuple [ str , List [ TextContent ]]] = await asyncio .gather (* tool_tasks )
73+ tool_results = await asyncio .gather (* tool_tasks )
7474
7575 # Add all tool results to messages (they will be in the same order as tool_calls)
7676 for tool_call , (tool_call_id , content ) in zip (message .tool_calls , tool_results ):
@@ -126,7 +126,7 @@ async def default_agent_rollout_processor(
126126 async def process_row (row : EvaluationRow ) -> EvaluationRow :
127127 """Process a single row with agent rollout."""
128128 agent = Agent (
129- model = config .completion_params . model , row = row , config_path = config .mcp_config_path , logger = config .logger
129+ model = config .completion_params [ " model" ] , row = row , config_path = config .mcp_config_path , logger = config .logger
130130 )
131131 try :
132132 await agent .setup ()
0 commit comments