Function mergeWorkflowStepRecords

src/node/services/workflows/WorkflowRunStore.ts:1101–1121

(
  records: readonly WorkflowStepRecord[],
  nextRecord?: WorkflowStepRecord
)

}

function mergeWorkflowStepRecords(
  records: readonly WorkflowStepRecord[],
  nextRecord?: WorkflowStepRecord
): WorkflowStepRecord[] {
  const byKey = new Map<string, WorkflowStepRecord>();
  const mergeRecord = (record: WorkflowStepRecord): void => {
    const key = getWorkflowStepKey(record);
    const previous = byKey.get(key);
    byKey.set(key, {
      ...record,
      timeout: mergeWorkflowStepTimeoutMetadata(previous, record),
    });
  };
  for (const record of records) {
    mergeRecord(record);
  }
  if (nextRecord !== undefined) {
    mergeRecord(nextRecord);
  }
  return Array.from(byKey.values());
}

function mergeWorkflowStepTimeoutMetadata(
  previous: WorkflowStepRecord | undefined,