Method
JobRetry
(ctx context.Context, exec riverdriver.Executor, params *riverdriver.JobRetryParams)
Source from the content-addressed store, hash-verified
| 80 | } |
| 81 | |
| 82 | func (p *pilotSpy) JobRetry(ctx context.Context, exec riverdriver.Executor, params *riverdriver.JobRetryParams) (*rivertype.JobRow, error) { |
| 83 | p.jobRetryCalls.Add(1) |
| 84 | return p.StandardPilot.JobRetry(ctx, exec, params) |
| 85 | } |
| 86 | |
| 87 | func (p *pilotSpy) JobSetStateIfRunningMany(ctx context.Context, exec riverdriver.Executor, params *riverdriver.JobSetStateIfRunningManyParams) ([]*rivertype.JobRow, error) { |
| 88 | p.testSignals.JobSetStateIfRunningMany.Signal(struct{}{}) |
Callers
nothing calls this directly
Tested by
no test coverage detected