Method getActiveWorkflowRunIds

src/node/services/workspaceService.ts:2269–2293

(workspaceId: string)

  }

  private async getActiveWorkflowRunIds(workspaceId: string): Promise<Set<string>> {
    assert(workspaceId.length > 0, "getActiveWorkflowRunIds requires workspaceId");
    const cached = this.activeWorkflowRunIdsByWorkspace.get(workspaceId);
    if (cached != null) {
      const bootstrap = this.activeWorkflowRunIdBootstrapsByWorkspace.get(workspaceId);
      if (bootstrap != null) {
        await bootstrap;
      }
      return cached;
    }

    // Install the shared Set before awaiting disk so parallel workflow status events
    // mutate the same cache instead of racing to replace each other after bootstrap.
    const activeRunIds = new Set<string>();
    this.activeWorkflowRunIdsByWorkspace.set(workspaceId, activeRunIds);
    const bootstrap = this.populateActiveWorkflowRunIds(workspaceId, activeRunIds);
    this.activeWorkflowRunIdBootstrapsByWorkspace.set(workspaceId, bootstrap);
    try {
      return await bootstrap;
    } finally {
      if (this.activeWorkflowRunIdBootstrapsByWorkspace.get(workspaceId) === bootstrap) {
        this.activeWorkflowRunIdBootstrapsByWorkspace.delete(workspaceId);
      }
    }
  }

  private async getActiveWorkflowRunCount(workspaceId: string): Promise<number> {
    return (await this.getActiveWorkflowRunIds(workspaceId)).size;