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

Method NextRetry

worker.go:51–51  ·  view source on GitHub ↗

NextRetry calculates when the next retry for a failed job should take place given when it was last attempted and its number of attempts, or any other of the job's properties a user-configured retry policy might want to consider. Note that this method on a worker overrides any client-level retry pol

(job *Job[T])

Source from the content-addressed store, hash-verified

49 // To use the client-level retry policy, return an empty `time.Time{}` or
50 // include WorkerDefaults to do this for you.
51 NextRetry(job *Job[T]) time.Time
52
53 // Timeout is the maximum amount of time the job is allowed to run before
54 // its context is cancelled. A timeout of zero (the default) means the job

Callers 4

Test_Client_RetryPolicyFunction · 0.65
NextRetryMethod · 0.65
NextRetryMethod · 0.65

Implementers 2

callbackWorkUnitinternal/maintenance/job_rescuer_test.
customizableWorkUnitinternal/jobexecutor/job_executor_test

Calls

no outgoing calls

Tested by 2

Test_Client_RetryPolicyFunction · 0.52