MCPcopy Create free account
hub / github.com/riverqueue/river / NextRetry

Method NextRetry

rivertest/work_unit_wrapper.go:56–56  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

54 return w.worker.Middleware(w.jobRow)
55}
56func (w *wrapperWorkUnit[T]) NextRetry() time.Time { return w.worker.NextRetry(w.job) }
57func (w *wrapperWorkUnit[T]) Timeout() time.Duration { return w.worker.Timeout(w.job) }
58func (w *wrapperWorkUnit[T]) Work(ctx context.Context) error { return w.worker.Work(ctx, w.job) }
59

Callers

nothing calls this directly

Calls 1

NextRetryMethod · 0.65

Tested by

no test coverage detected