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

Method JobSetStateIfRunningMany

rivershared/riverpilot/pilot.go:46–46  ·  view source on GitHub ↗
(ctx context.Context, exec riverdriver.Executor, params *riverdriver.JobSetStateIfRunningManyParams)

Source from the content-addressed store, hash-verified

44 JobRetry(ctx context.Context, exec riverdriver.Executor, params *riverdriver.JobRetryParams) (*rivertype.JobRow, error)
45
46 JobSetStateIfRunningMany(ctx context.Context, exec riverdriver.Executor, params *riverdriver.JobSetStateIfRunningManyParams) ([]*rivertype.JobRow, error)
47
48 PilotInit(archetype *baseservice.Archetype, params *PilotInitParams)
49

Callers 8

JobCompleteTxFunction · 0.65
JobSetStateIfRunningManyMethod · 0.65
JobSetStateIfRunningManyMethod · 0.65
JobSetStateIfRunningManyMethod · 0.65
testCompleterFunction · 0.65
JobSetStateIfRunningMethod · 0.65
JobSetStateIfRunningMethod · 0.65
handleBatchMethod · 0.65

Implementers 2

pilotSpyclient_pilot_test.go
StandardPilotrivershared/riverpilot/standard_pilot.

Calls

no outgoing calls

Tested by 3

JobSetStateIfRunningManyMethod · 0.52
JobSetStateIfRunningManyMethod · 0.52
testCompleterFunction · 0.52