Function inference_with_reflection

tests/leetcode_reflection_agent.py:853–1098

带反思的推理：生成代码 -> 评测 -> 反思改进 -> 再评测，最多MAX_REFLECTION_ROUNDS轮

(
    task: Task,
    save_dir: str,
    semaphore: asyncio.Semaphore,
    benchmark: Any,
)

async def inference_with_reflection(
    task: Task,
    save_dir: str,
    semaphore: asyncio.Semaphore,
    benchmark: Any,
) -> Task:
    """
    带反思的推理：生成代码 -> 评测 -> 反思改进 -> 再评测，最多MAX_REFLECTION_ROUNDS轮
    """
    task_id = task.task_id
    
    async with semaphore:
        inference_start_time = time.time()
        task.extra["inference_start_time"] = inference_start_time
        
        current_code = ""
        current_reasoning = ""
        best_score = 0.0
        best_code = ""
        best_reasoning = ""
        best_eval_result = None
        
        try:
            logger.info(f"| 🚀 [Task {task_id}] Starting inference with reflection...")
            
            # ============ Round 1: 初始生成 ============
            logger.info(f"| 🔄 [Task {task_id}] Round 1: Generating initial solution...")
            
            try:
                initial_response = await generate_initial_solution(task, TARGET_MODEL)
                current_reasoning = initial_response.reasoning
                current_code = initial_response.result
                
                logger.info(f"| ✅ [Task {task_id}] Round 1: Initial solution generated")
                
            except Exception as e:
                logger.error(f"| ❌ [Task {task_id}] Round 1: Failed to generate initial solution: {e}")
                task.reasoning = ""
                task.result = ""
                task.extra["inference_time"] = time.time() - inference_start_time
                task.extra["final_round"] = 0
                task.extra["error"] = str(e)
                return task
            
            # 保存初始代码
            try:
                file_name = f"{task.extra['file_name']}_round1.md"
                file_path = os.path.join(save_dir, file_name)
                with open(file_path, "w", encoding="utf-8") as f:
                    f.write(f"# Round 1 - Initial Solution\n\n")
                    f.write(f"## Reasoning\n{current_reasoning}\n\n")
                    f.write(f"## Code\n```\n{current_code}\n```\n")
            except Exception as save_err:
                logger.warning(f"| ⚠️ [Task {task_id}] Failed to save round 1 markdown: {save_err}")
            
            # ============ 迭代评测和反思 ============
            for round_num in range(1, MAX_REFLECTION_ROUNDS + 1):
                logger.info(f"| 📊 [Task {task_id}] Round {round_num}: Evaluating solution...")