Method withStepRecord

src/node/services/workflows/WorkflowRunStore.ts:968–973

(run: WorkflowRunRecord, record: WorkflowStepRecord)

  }

  private withStepRecord(run: WorkflowRunRecord, record: WorkflowStepRecord): WorkflowRunRecord {
    return WorkflowRunRecordSchema.parse({
      ...run,
      steps: mergeWorkflowStepRecords(run.steps, record),
    });
  }

  private async readEvents(runId: string): Promise<WorkflowRunEvent[]> {
    const events = await readJsonLines(this.eventsFile(runId), WorkflowRunEventSchema);