dag-scheduler / Exports / SchedulerTriggerService
Class: SchedulerTriggerService
Scheduler service that delegates scheduled, batch, and catchup triggers to the runtime RunOrchestratorService. Validates catchup parameters (date ranges, slot intervals, max slots) before dispatching.
See
RunOrchestratorService for the underlying run creation and dispatch
Table of contents
Constructors
Methods
Constructors
constructor
• new SchedulerTriggerService(runOrchestrator): SchedulerTriggerService
Parameters
| Name | Type |
|---|---|
runOrchestrator | RunOrchestratorService |
Returns
Defined in
services/scheduler-trigger-service.ts:60
Methods
triggerScheduledRun
▸ triggerScheduledRun(request): Promise<TResult<IStartRunResult, IDagError>>
Triggers a single scheduled DAG run.
Parameters
| Name | Type | Description |
|---|---|---|
request | IScheduledTriggerRequest | The trigger request with DAG ID, logical date, and input. |
Returns
Promise<TResult<IStartRunResult, IDagError>>
The started run result or an error.
Defined in
services/scheduler-trigger-service.ts:69
triggerScheduledBatch
▸ triggerScheduledBatch(request): Promise<TResult<IScheduledBatchTriggerResult, IDagError>>
Triggers a batch of scheduled runs sequentially. If a failure occurs mid-batch, returns successfully started runs with a partial error.
Parameters
| Name | Type | Description |
|---|---|---|
request | IScheduledBatchTriggerRequest | The batch request containing multiple trigger items. |
Returns
Promise<TResult<IScheduledBatchTriggerResult, IDagError>>
The batch result with started runs and optional partial error.
Defined in
services/scheduler-trigger-service.ts:87
triggerCatchup
▸ triggerCatchup(request): Promise<TResult<ICatchupTriggerResult, IDagError>>
Triggers runs for each time slot in a catchup date range. Validates date range, slot interval, and max-slot constraints before dispatching.
Parameters
| Name | Type | Description |
|---|---|---|
request | ICatchupTriggerRequest | The catchup request with date range, interval, and slot limit. |
Returns
Promise<TResult<ICatchupTriggerResult, IDagError>>
The catchup result with slot count and started runs, or a validation error.