createDurableWorker

@forge/monorepo

---

@forge/monorepo / backend/src / createDurableWorker

Function: createDurableWorker()

createDurableWorker(deps): object

Defined in: backend/src/runtime/worker.ts:179

Parameters

deps

DurableWorkerDeps

Returns

process()

process(input): Promise<ProcessResult>

Claim (under an optional lock) and drive a run. Idempotent: a claimed/terminal run is skipped.

Parameters

input

runId

RunId

tenantId

TenantId

Returns

Promise<ProcessResult>

reapExpired()

reapExpired(limit?): Promise<readonly Run[]>

Recover runs whose lease expired (crashed workers). Returns the reclaimed candidates; a caller re-enqueues each via its JobDispatcher. Kept separate so recovery cadence is the host's call.

Parameters

limit?

number = 20

Returns

Promise<readonly Run[]>