Function ResumableSetStepCursorTx

resumable_step_tx.go:45–52

ResumableSetStepCursorTx immediately persists the current resumable step and cursor as part of transaction tx. If tx is rolled back, the step and cursor 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 suffici

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

// Must be called from within a ResumableStepCursor callback. The current step
// name to persist is read from context.
func ResumableSetStepCursorTx[TDriver riverdriver.Driver[TTx], TTx any, TArgs JobArgs, TCursor any](ctx context.Context, tx TTx, job *Job[TArgs], cursor TCursor) (*Job[TArgs], error) {
	cursorBytes, err := json.Marshal(cursor)
	if err != nil {
		return nil, err
	}

	return resumableSetStepTx(ctx, tx, job, json.RawMessage(cursorBytes))
}

func resumableSetStepTx[TTx any, TArgs JobArgs](ctx context.Context, tx TTx, job *Job[TArgs], cursor json.RawMessage) (*Job[TArgs], error) {
	if job.State != rivertype.JobStateRunning {