Method countActiveWorkspaceTurns

src/node/services/taskService.ts:6648–6682

(
    records?: readonly WorkspaceTurnTaskHandleRecord[]
  )

  }

  private async countActiveWorkspaceTurns(
    records?: readonly WorkspaceTurnTaskHandleRecord[]
  ): Promise<number> {
    const candidateWorkspaceTurns =
      records ??
      (await this.taskHandleStore.listAllWorkspaceTurns({
        statuses: ["queued", "starting", "running"],
      }));
    let count = 0;
    const countedWorkspaceIds = new Set<string>();
    const queuedRecords: WorkspaceTurnTaskHandleRecord[] = [];
    for (const record of candidateWorkspaceTurns) {
      if (!this.isActiveWorkspaceTurn(record)) {
        continue;
      }
      if (!(await this.isLiveWorkspaceTurn(record))) {
        await this.settleStaleWorkspaceTurn(record);
        continue;
      }
      if (record.status === "queued") {
        queuedRecords.push(record);
        continue;
      }
      count += 1;
      countedWorkspaceIds.add(record.workspaceId);
    }
    for (const record of queuedRecords) {
      if (countedWorkspaceIds.has(record.workspaceId)) {
        continue;
      }
      count += 1;
      countedWorkspaceIds.add(record.workspaceId);
    }
    return count;
  }

  private async listActiveWorkspaceTurnTaskIdsForOwner(
    ownerWorkspaceId: string