dag-runtime / Exports / RunOrchestratorService
Class: RunOrchestratorService
Orchestrates the lifecycle of DAG runs: creation, validation, state transitions, and entry-task dispatch.
See
- IStoragePort for persistence contracts
- IQueuePort for task queue contracts
- DagRunStateMachine for run state transitions
Table of contents
Constructors
Methods
Constructors
constructor
• new RunOrchestratorService(storage, queue, clock, runProgressEventReporter?): RunOrchestratorService
Parameters
| Name | Type |
|---|---|
storage | IStoragePort |
queue | IQueuePort |
clock | IClockPort |
runProgressEventReporter? | IRunProgressEventReporter |
Returns
Defined in
services/run-orchestrator-service.ts:57
Methods
createRun
▸ createRun(input): Promise<TResult<ICreateRunResult, IDagError>>
Creates a DAG run record without dispatching tasks. Validates the definition, resolves time semantics, and enforces idempotency via run key.
Parameters
| Name | Type |
|---|---|
input | IStartRunInput |
Returns
Promise<TResult<ICreateRunResult, IDagError>>
Defined in
services/run-orchestrator-service.ts:70
startCreatedRun
▸ startCreatedRun(dagRunId): Promise<TResult<IStartRunResult, IDagError>>
Transitions a previously created run to running and dispatches entry tasks to the queue.
Parameters
| Name | Type |
|---|---|
dagRunId | string |
Returns
Promise<TResult<IStartRunResult, IDagError>>
Defined in
services/run-orchestrator-service.ts:119
startRun
▸ startRun(input): Promise<TResult<IStartRunResult, IDagError>>
Creates and starts a DAG run in a single call.
Parameters
| Name | Type |
|---|---|
input | IStartRunInput |
Returns
Promise<TResult<IStartRunResult, IDagError>>