Method settleInterruptedTaskAtStreamEnd

src/node/services/taskService.ts:8684–8719

* Stream-end settlement for interrupted tasks. Guarantees every pending waiter * is settled exactly once: resolved if an agent_report exists, rejected otherwise. * No waiter should depend on timeout to discover terminal interruption.

(
    workspaceId: string,
    entry: { projectPath: string; workspace: WorkspaceConfigEntry },
    reportArgs: {
      reportMarkdown: string;
      title?: string;
      structuredOutput?: unknown;
      planFilePath?: string;
    } | null,
    options?: { rejectionError?: Error }
  )

   * No waiter should depend on timeout to discover terminal interruption.
   */
  private async settleInterruptedTaskAtStreamEnd(
    workspaceId: string,
    entry: { projectPath: string; workspace: WorkspaceConfigEntry },
    reportArgs: {
      reportMarkdown: string;
      title?: string;
      structuredOutput?: unknown;
      planFilePath?: string;
    } | null,
    options?: { rejectionError?: Error }
  ): Promise<void> {
    if (reportArgs) {
      const finalization = await this.finalizeAgentTaskReport(workspaceId, entry, reportArgs);
      if (!finalization.finalized) {
        this.rejectWaiters(workspaceId, new Error(finalization.message));
      }
      return;
    }

    this.rejectWaiters(workspaceId, options?.rejectionError ?? new Error("Task interrupted"));

    const parentWorkspaceId = entry.workspace.parentWorkspaceId;
    const bestOf = entry.workspace.bestOf;
    if (
      parentWorkspaceId &&
      bestOf?.total != null &&
      bestOf.total > 1 &&
      !this.aiService.isStreaming(parentWorkspaceId)
    ) {
      await this.deliverDeferredBestOfSiblingReports({
        parentWorkspaceId,
        groupId: bestOf.groupId,
        total: bestOf.total,
      });
    }
  }

  private async handleSuccessfulWorkflowProposePlan(args: {
    workspaceId: string;