Function analyze_task

runner/mobiagent/multi_task/planner.py:215–264

分析任务是单阶段还是多阶段 Args: task_description: 任务描述 planner_client: Planner客户端 planner_model: Planner模型名称 experience_results: 经验检索结果（可选） temperature: 采样温度 Returns: (is_multi_stage, reason): (是否多阶段, 原因说明)

(
    task_description: str,
    planner_client: OpenAI,
    planner_model: str,
    experience_results: str = "",
    temperature: float = 0.0
)

def analyze_task(
    task_description: str,
    planner_client: OpenAI,
    planner_model: str,
    experience_results: str = "",
    temperature: float = 0.0
) -> Tuple[bool, Optional[str]]:
    """
    分析任务是单阶段还是多阶段
    
    Args:
        task_description: 任务描述
        planner_client: Planner客户端
        planner_model: Planner模型名称
        experience_results: 经验检索结果（可选）
        temperature: 采样温度
    
    Returns:
        (is_multi_stage, reason): (是否多阶段, 原因说明)
    """

    # 判断多任务、单任务较简单，不使用经验
    prompt = PLANNER_TASK_ANALYSIS_PROMPT.format(
        task_description=task_description
    )
    
    logging.info(f"任务分析prompt: \n{prompt}")
    
    response = planner_client.chat.completions.create(
        model=planner_model,
        messages=[{"role": "user", "content": prompt}],
        temperature=temperature
    )
    
    response_str = response.choices[0].message.content
    logging.info(f"任务分析响应: \n{response_str}")
    
    try:
        result = parse_planner_response(response_str)
        
        # 解析task_type字段
        task_type = result.get("task_type", "single")
        is_multi = (task_type == "multi")
        reason = result.get("reasoning", "")
        
        return is_multi, reason
    except Exception as e:
        logging.error(f"解析任务分析响应失败: {e}")
        # 默认返回单阶段
        return False, None


def generate_plan(