Function handle_execute_plan

src/harness/agentic_loop/tools.py:324–392

(args: dict)

    """

    def handle_execute_plan(args: dict) -> str:
        task_id = args["task_id"]
        task = task_board.get_task(task_id)
        if not task:
            return f"Error: Task {task_id} not found on the task board."

        # Guard: must have a generated and approved plan
        if not task.plan_file:
            return (
                f"Error: Task {task_id} has no plan file. "
                "Generate a plan with generate_plan first."
            )
        if not task.plan_verified:
            return (
                f"Error: Task {task_id} plan is not verified/approved. "
                "The plan must be generated and approved before execution."
            )

        plan_path = Path(task.plan_file)
        if not plan_path.exists():
            return f"Error: Plan file {task.plan_file} not found on disk."

        # Mark task as in_progress before execution
        task_board.update_task(task_id, status="in_progress")

        try:
            # Execute the plan in isolation (fresh Interpreter, no orchestrator context)
            execution_result = plan_executor.execute(
                plan_path=plan_path,
                model=args.get("model"),
            )

            # Summarize the raw result using a cheap LLM call —
            # only the compact summary enters the orchestrator's context,
            # not the full execution output (context isolation pattern)
            result_summary = summarize_fn(execution_result.output, task.description)

            status = "completed" if execution_result.success else "failed"
            task_board.update_task(
                task_id,
                status=status,
                result_summary=result_summary,
                error=(
                    "; ".join(execution_result.errors[:3])
                    if execution_result.errors
                    else None
                ),
            )

            status_line = "successfully" if execution_result.success else "with errors"
            error_line = (
                f"Errors: {'; '.join(execution_result.errors[:3])}\n"
                if execution_result.errors
                else ""
            )
            return (
                f"Plan executed {status_line} for {task_id}.\n"
                f"Steps: {execution_result.steps_completed}/{execution_result.steps_total}\n"