Method isLiveWorkspaceTurn

src/node/services/taskService.ts:6578–6601

(record: WorkspaceTurnTaskHandleRecord)

  }

  private async isLiveWorkspaceTurn(record: WorkspaceTurnTaskHandleRecord): Promise<boolean> {
    const active = this.activeWorkspaceTurnHandleByWorkspaceId.get(record.workspaceId);
    const hasRuntimeActivity =
      this.aiService.isStreaming(record.workspaceId) ||
      this.workspaceService.hasPendingQueuedOrPreparingTurn(record.workspaceId);
    if (hasRuntimeActivity) {
      return true;
    }

    const isActiveHandle =
      active?.handleId === record.handleId && active.ownerWorkspaceId === record.ownerWorkspaceId;
    if (!isActiveHandle) {
      return false;
    }

    if ((record.deferredMessageIds?.length ?? 0) === 0) {
      return true;
    }

    // A deferred workspace-turn stream-end was waiting for background work. Once there is no
    // live stream/queued retry and no active descendant/workflow/nested turn left, the in-memory
    // handle is stale and should be recovered from the deferred history instead of blocking forever.
    return await this.hasActiveWorkspaceTurnDeferredBlockers(record);
  }

  private async settleStaleWorkspaceTurn(record: WorkspaceTurnTaskHandleRecord): Promise<void> {
    if (record.status !== "queued" && record.status !== "starting" && record.status !== "running") {