ResumableStepAfter configures insert options so that the job resumes after the named step. When the job is worked, all steps up to and including the named step will be skipped, and execution will begin at the next step. Used with [Worker.Work], simulates a job that previously completed the named st
(opts *river.InsertOpts, stepName string)
| 18 | // result, err := testWorker.Work(ctx, t, tx, args, |
| 19 | // rivertest.ResumableStepAfter(&river.InsertOpts{}, "step1")) |
| 20 | func ResumableStepAfter(opts *river.InsertOpts, stepName string) *river.InsertOpts { |
| 21 | mergeResumableMetadata(opts, stepName, nil) |
| 22 | return opts |
| 23 | } |
| 24 | |
| 25 | // ResumableStepAtCursor configures insert options so that the job resumes at |
| 26 | // the named step with the provided cursor data. The named step and all |
searching dependent graphs…