Function process_task

tests/leetcode_reflection_agent.py:1178–1210

处理单个任务

(task: Task)

    start_time = time.time()
    
    async def process_task(task: Task):
        """处理单个任务"""
        result_task = await inference_with_reflection(
            task=task,
            save_dir=save_dir,
            semaphore=inference_semaphore,
            benchmark=benchmark,
        )
        
        async with stats_lock:
            stats["completed"] += 1
            score = result_task.score or 0.0
            
            if score >= 1.0:
                stats["accepted"] += 1
            elif score > 0:
                stats["partial"] += 1
            else:
                stats["failed"] += 1
            
            final_round = result_task.extra.get("final_round", MAX_REFLECTION_ROUNDS)
            stats["total_rounds"] += final_round
            
            # 打印进度
            print(f"\r🔄 Progress: {stats['completed']}/{total_tasks} | "
                  f"✅ Accepted: {stats['accepted']} | "
                  f"🔶 Partial: {stats['partial']} | "
                  f"❌ Failed: {stats['failed']}", end="", flush=True)
        
        # 保存最终结果
        await save_final_result(result_task, benchmark, save_dir)
        
        return result_task
    
    # 启动所有任务
    print(f"🚀 Starting self-reflection inference...\n")