Method markWorkspaceTurnStreamEndDeferred

src/node/services/taskService.ts:7747–7772

(event: StreamEndEvent)

  }

  private async markWorkspaceTurnStreamEndDeferred(event: StreamEndEvent): Promise<void> {
    const metadata = this.getWorkspaceTurnMetadata(event);
    if (metadata == null) {
      return;
    }
    await this.workspaceTurnSettlementLocks.withLock(metadata.taskHandleId, async () => {
      const record = await this.taskHandleStore.getWorkspaceTurn(
        metadata.ownerWorkspaceId,
        metadata.taskHandleId
      );
      if (
        record == null ||
        record.workspaceId !== event.workspaceId ||
        record.turnId !== metadata.turnId ||
        !this.isActiveWorkspaceTurn(record) ||
        this.isDeferredWorkspaceTurnMessage(record, event.messageId)
      ) {
        return;
      }
      await this.taskHandleStore.upsertWorkspaceTurn({
        ...record,
        updatedAt: getIsoNow(),
        deferredMessageIds: [...(record.deferredMessageIds ?? []), event.messageId],
      });
    });
  }

  private resolveWorkspaceTurnMuxMetadataForStreamEnd(
    event: StreamEndEvent