Method getRun

src/node/services/workflows/WorkflowRunStore.ts:205–212

(runId: string)

  }

  async getRun(runId: string): Promise<WorkflowRunRecord> {
    // UI polling must not wait behind the writer lock; while a mutation is in progress,
    // fall back to the last atomic run.json snapshot instead of reading half-updated journals.
    if (await this.hasActiveWorkflowMutationLock(runId)) {
      return await this.getRunFileSnapshot(runId);
    }
    return await this.getRunUnlocked(runId);
  }

  async getRunStatusSnapshot(runId: string): Promise<WorkflowRunStatusSnapshot> {
    assertValidWorkflowRunId(runId);