Interface SweepExpiredRunDeadlinesOptions

interface SweepExpiredRunDeadlinesOptions {
    cursor?: RunDeadlineCursor;
    limit?: number;
    now?: () => number;
    tablePrefix?: string;
    advanceCursor?(cursor: RunDeadlineCursor): Promise<void>;
    transition(candidate: RunDeadlineCandidate, now: number): Promise<void>;
}

Index

Properties

cursor? limit? now? tablePrefix?

Methods

advanceCursor? transition

Properties

`Optional`cursor

cursor?: RunDeadlineCursor

Last selected row from the prior pass.

`Optional`limit

limit?: number

Bounded rows per duty pass. Default 100.

`Optional`now

now?: () => number

`Optional`tablePrefix

tablePrefix?: string

Must satisfy createD1Storage's max-39 tablePrefix contract.

Methods

`Optional`advanceCursor

advanceCursor?(cursor: RunDeadlineCursor): Promise<void>
Persists progress after every selected row, including failed rows.
Parameters
- cursor: RunDeadlineCursor
Returns Promise<void>
- Defined in packages/flowsafe/src/do-runner/d1-storage.ts:147

transition

transition(candidate: RunDeadlineCandidate, now: number): Promise<void>
Routes the CAS through the run's owner Durable Object.
Parameters
- candidate: RunDeadlineCandidate
- now: number
Returns Promise<void>
- Defined in packages/flowsafe/src/do-runner/d1-storage.ts:149