Function ResumableStep

resumable.go:57–84

ResumableStep runs a resumable step, skipping the step on a later retry if an earlier attempt already completed it successfully. Step names must be unique across all ResumableStep and ResumableStepCursor calls in the same Worker execution. After a step returns an error, no subsequent steps will be

(ctx context.Context, name string, opts *StepOpts, stepFunc func(ctx context.Context) error)

//
// opts may be nil.
func ResumableStep(ctx context.Context, name string, opts *StepOpts, stepFunc func(ctx context.Context) error) {
	state := mustResumableState(ctx)
	if state.Err != nil {
		return
	}
	if !registerResumableStepName(state, name) {
		return
	}

	if !state.ResumeMatched {
		if name == state.ResumeStep {
			state.CompletedStep = name
			state.ResumeMatched = true
		}
		return
	}

	previousStepName := state.StepName
	state.StepName = name
	defer func() { state.StepName = previousStepName }()

	if err := stepFunc(ctx); err != nil {
		state.Err = err
		return
	}

	state.CompletedStep = name
}

// ResumableStepCursor runs a resumable step that also receives a persisted
// cursor value from an earlier failed attempt, if one was recorded with