Method getSteps

src/node/services/workflows/WorkflowRunStore.ts:673–689

(
    runId: string,
    lookups: readonly WorkflowStepLookup[]
  )

  }

  async getSteps(
    runId: string,
    lookups: readonly WorkflowStepLookup[]
  ): Promise<Array<WorkflowStepRecord | null>> {
    if (lookups.length === 0) {
      return [];
    }
    const requestedKeys = new Set(lookups.map(getWorkflowStepKey));
    const byKey = new Map<string, WorkflowStepRecord>();
    for (const step of await this.readSteps(runId)) {
      const key = getWorkflowStepKey(step);
      if (requestedKeys.has(key)) {
        byKey.set(key, step);
      }
    }
    return lookups.map((lookup) => byKey.get(getWorkflowStepKey(lookup)) ?? null);
  }

  async acquireLease(runId: string, ownerId: string, nowMs = Date.now()): Promise<boolean> {
    assert(ownerId.length > 0, "WorkflowRunStore.acquireLease: ownerId is required");