Method handleSuccessfulWorkflowProposePlan

src/node/services/taskService.ts:8721–8816

(args: {
    workspaceId: string;
    entry: { projectPath: string; workspace: WorkspaceConfigEntry };
    proposePlanResult: { planPath: string };
  })

  }

  private async handleSuccessfulWorkflowProposePlan(args: {
    workspaceId: string;
    entry: { projectPath: string; workspace: WorkspaceConfigEntry };
    proposePlanResult: { planPath: string };
  }): Promise<void> {
    assert(
      args.workspaceId.length > 0,
      "handleSuccessfulWorkflowProposePlan: workspaceId must be non-empty"
    );
    assert(
      args.proposePlanResult.planPath.length > 0,
      "handleSuccessfulWorkflowProposePlan: planPath must be non-empty"
    );

    if (args.entry.workspace.workflowTask?.outputSchema !== undefined) {
      const error = new Error(
        "Workflow plan agents return { reportMarkdown, planFilePath }; do not provide schema/outputSchema."
      );
      await this.editWorkspaceEntry(
        args.workspaceId,
        (workspace) => {
          workspace.taskStatus = "interrupted";
          workspace.taskLaunchError = error.message;
        },
        { allowMissing: true }
      );
      this.rejectWaiters(args.workspaceId, error);
      await this.emitWorkspaceMetadata(args.workspaceId);
      return;
    }

    let planSummary: { content: string; path: string } | null = null;
    try {
      const info = await this.workspaceService.getInfo(args.workspaceId);
      if (!info) {
        log.error("Workflow plan completion could not read workspace metadata", {
          workspaceId: args.workspaceId,
        });
      } else {
        const runtime = createRuntimeForWorkspace(info);
        const planResult = await readPlanFile(
          runtime,
          info.name,
          info.projectName,
          args.workspaceId
        );
        if (planResult.exists && planResult.content.trim().length > 0) {
          if (planResult.path !== args.proposePlanResult.planPath) {
            log.debug("Workflow plan completion using canonical plan file path", {
              workspaceId: args.workspaceId,
              proposedPlanPath: args.proposePlanResult.planPath,
              canonicalPlanPath: planResult.path,
            });
          }
          planSummary = { content: planResult.content, path: planResult.path };
        } else {
          log.error("Workflow plan completion did not find non-empty plan file content", {
            workspaceId: args.workspaceId,