MCPcopy Index your code
hub / github.com/riverqueue/river / ResumableStepAfter

Function ResumableStepAfter

rivertest/resumable.go:20–23  ·  view source on GitHub ↗

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)

Source from the content-addressed store, hash-verified

18// result, err := testWorker.Work(ctx, t, tx, args,
19// rivertest.ResumableStepAfter(&river.InsertOpts{}, "step1"))
20func 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

Callers 2

TestResumableStepAfterFunction · 0.85

Calls 1

mergeResumableMetadataFunction · 0.85

Tested by 2

TestResumableStepAfterFunction · 0.68

Used in the wild real call sites across dependent graphs

searching dependent graphs…