Function ResumableSetStepTx

resumable_step_tx.go:28–30

ResumableSetStepTx immediately persists the current resumable step as part of transaction tx. If tx is rolled back, the step update will be as well. Normally, a resumable job's step progress is recorded after it runs along with its result status. This is normally sufficient, but because it happens

(ctx context.Context, tx TTx, job *Job[TArgs])

// Must be called from within a ResumableStep or ResumableStepCursor callback.
// The current step name to persist is read from context.
func ResumableSetStepTx[TDriver riverdriver.Driver[TTx], TTx any, TArgs JobArgs](ctx context.Context, tx TTx, job *Job[TArgs]) (*Job[TArgs], error) {
	return resumableSetStepTx(ctx, tx, job, nil)
}

// ResumableSetStepCursorTx immediately persists the current resumable step and
// cursor as part of transaction tx. If tx is rolled back, the step and cursor