dag-worker / Exports / WorkerLoopService
Class: WorkerLoopService
Processes task messages from the queue one at a time: dequeue, acquire lease, execute via the task executor, handle success/failure paths including retry and dead-letter routing, and finalize the DAG run when all tasks are terminal.
See
- ITaskExecutorPort for task execution contracts
- ILeasePort for distributed lease contracts
- TaskRunStateMachine for task state transitions
Table of contents
Constructors
Methods
Constructors
constructor
• new WorkerLoopService(storage, queue, lease, executor, clock, options, runProgressEventReporter?): WorkerLoopService
Parameters
| Name | Type |
|---|---|
storage | IStoragePort |
queue | IQueuePort |
lease | ILeasePort |
executor | ITaskExecutorPort |
clock | IClockPort |
options | IWorkerLoopOptions |
runProgressEventReporter? | IRunProgressEventReporter |
Returns
Defined in
services/worker-loop-service.ts:60
Methods
processOnce
▸ processOnce(): Promise<TResult<IWorkerLoopResult, IDagError>>
Dequeues and processes a single task message.
Returns
Promise<TResult<IWorkerLoopResult, IDagError>>