Threads processed per call. Default 100 — the shrinking eligible set is the
cursor, so a first backlog drains across firings instead of blowing one
invocation's budget (same batching rationale as purgeExpiredWorkflowRuns).
Optionalnow
now?:()=>number
Clock override for tests.
OptionaltablePrefix
tablePrefix?:string
Must match createD1Storage's tablePrefix.
ttlMs
ttlMs:number
Threads untouched for longer than this are eligible, with their messages.
Threads processed per call. Default 100 — the shrinking eligible set is the cursor, so a first backlog drains across firings instead of blowing one invocation's budget (same batching rationale as purgeExpiredWorkflowRuns).