createSweepJobRunner

function createSweepJobRunner(runtime, opts?): (job) => Promise<void>;

Registers both recoverOrphanedRuns and sweepDeadlines as the handler for kuralle.sweep jobs.

Exactly one sweeper per RunStore. The run mutex is in-process only; two schedulers against the same store race recoveries of the same orphan.

Parameters

Parameter	Type
runtime	SweepRuntime
opts?	{ onError?: (error, job) => void; reschedule?: (job) => Promise<string>; }
opts.onError?	(error, job) => void
opts.reschedule?	(job) => Promise<string>

Returns

(job) => Promise<void>