Method finalizeWorkspaceTurnFromStreamEnd

src/node/services/taskService.ts:7876–7916

(event: StreamEndEvent)

  }

  private async finalizeWorkspaceTurnFromStreamEnd(event: StreamEndEvent): Promise<boolean> {
    const metadata = this.getWorkspaceTurnMetadata(event);
    if (metadata == null) {
      if (event.metadata.muxMetadata != null) {
        return false;
      }
      return await this.interruptWorkspaceTurnFromUncorrelatedStreamEnd(event);
    }
    const record = await this.taskHandleStore.getWorkspaceTurn(
      metadata.ownerWorkspaceId,
      metadata.taskHandleId
    );
    if (record == null) {
      log.warn("Ignoring missing workspace turn stream-end handle", {
        workspaceId: event.workspaceId,
        taskHandleId: metadata.taskHandleId,
      });
      return true;
    }
    if (record.workspaceId !== event.workspaceId || record.turnId !== metadata.turnId) {
      log.warn("Ignoring out-of-scope workspace turn stream-end", {
        workspaceId: event.workspaceId,
        taskHandleId: metadata.taskHandleId,
      });
      return true;
    }
    if (this.isDeferredWorkspaceTurnMessage(record, event.messageId)) {
      return true;
    }

    const next = this.buildTerminalWorkspaceTurnRecordFromEvent(record, event);
    await this.settleWorkspaceTurn({
      record,
      next,
      waiterSettlement:
        next.status === "completed"
          ? { status: "completed", result: this.buildWorkspaceTurnWaitResult(next) }
          : { status: "error", error: new Error(next.error ?? "Workspace turn failed") },
    });
    return true;
  }

  private async handleStreamEnd(event: StreamEndEvent): Promise<void> {
    const workspaceId = event.workspaceId;