Method ActivateDueJobsAsync

Namespace

Millrace.Storage

Assembly

Millrace.dll

ActivateDueJobsAsync(DateTimeOffset, int, CancellationToken)

Moves due Scheduled/Failed jobs (DueAt <= now) to Enqueued, clearing DueAt, in DueAt ASC order (oldest first; ties by enqueue order), up to batchSize; returns the number moved. Safe to run concurrently on every node — each job activates exactly once.

ValueTask<int> ActivateDueJobsAsync(DateTimeOffset now, int batchSize, CancellationToken ct)

Parameters

now DateTimeOffset

batchSize int

ct CancellationToken

Returns

ValueTask<int>