Function process_single_task

examples/run_benchmark.py:183–316

处理单个任务的协程函数

(task: Task, result_saver: Optional[BenchmarkResultSaver] = None)

    completed_lock = asyncio.Lock()
    
    async def process_single_task(task: Task, result_saver: Optional[BenchmarkResultSaver] = None) -> Task:
        """处理单个任务的协程函数"""
        nonlocal completed_count  # 必须在函数开始处声明
        task_id = task.task_id
        start_time = time.time()
        
        async with semaphore:  # 使用 Semaphore 限制并发
            try:
                print(f"\n" + "="*50)
                print(f"🚀 Processing Task ID: {task_id}")
                print("="*50)

                # --- 1. 准备 Prompt ---
                question_text = task.input
                
                # 直接从 task 获取 system_prompt
                system_prompt_text = task.system_prompt
                
                logger.info(f"| 📋 [Task {task_id}] Input length: {len(question_text)}")

                messages = [
                    SystemMessage(content=system_prompt_text),
                    HumanMessage(content=question_text)
                ]

                # --- 2. 模型推理 (Structure Output) ---
                print(f"⏳ [Task {task_id}] Model inferencing (Structured)...")
                
                try:
                    # 调用 model_manager 并传入 response_format，添加超时
                    try:
                        response = await asyncio.wait_for(
                            model_manager(
                                model=TARGET_MODEL,
                                messages=messages,
                                response_format=Response,
                            ),
                            timeout=600.0  # 10分钟超时
                        )
                    except asyncio.TimeoutError:
                        logger.error(f"| ⏱️ [Task {task_id}] Model API Timeout (600s)")
                        task.reasoning = ""
                        task.result = ""
                        response = None
                    
                    if response and response.success:
                        # 获取解析后的对象
                        response_model = response.extra.parsed_model
                        task.reasoning = response_model.reasoning
                        task.result = response_model.answer
                        
                        # --- 保存 Response 到 Markdown 文件 ---
                        try:
                            safe_id = sanitize_filename(task_id)
                            filename = f"{safe_id}.md"
                            file_path = os.path.join(save_dir, filename)
                            
                            with open(file_path, "w", encoding="utf-8") as f: