StepExecutor constructor

StepExecutor({
  1. required CheckpointStore store,
  2. required String workflowExecutionId,
  3. RetryExecutor? retryExecutor,
  4. Future<void> delayFn(
    1. Duration delay
    )?,
  5. StepNameMismatchWarning? onStepNameMismatch,
})

Creates a StepExecutor.

retryExecutor is injectable for testing. onStepNameMismatch is called when a replayed step's name differs from the checkpointed name. Defaults to printing a warning to stdout.

Implementation

StepExecutor({
  required CheckpointStore store,
  required String workflowExecutionId,
  RetryExecutor? retryExecutor,
  this.delayFn,
  StepNameMismatchWarning? onStepNameMismatch,
})  : _store = store,
      _workflowExecutionId = workflowExecutionId,
      _retryExecutor = retryExecutor ?? RetryExecutor(),
      onStepNameMismatch = onStepNameMismatch ?? _defaultMismatchWarning;