Class PipelineOrchestrator

Orchestrates the execution of one or more ContentPipeline instances.

Key behaviours:

Error isolation: a failure in one pipeline does not abort others.
Parallel mode: when config.parallel = true all pipelines run via Promise.allSettled for throughput and robust error handling; otherwise they execute sequentially for predictable log output.
Result aggregation: all per-pipeline PipelineResult objects are merged into a single OrchestratorResult.

Index

Constructors

Properties

pipelines parallel defaultOptions

Methods

run _runSingle _aggregate

Constructors

constructor

new PipelineOrchestrator(config: OrchestratorConfig): PipelineOrchestrator
Parameters
- config: OrchestratorConfig
Returns PipelineOrchestrator
- Defined in scripts/pipeline/orchestrator.ts:52

Properties

`Private` `Readonly`pipelines

pipelines: ContentPipeline[]

`Private` `Readonly`parallel

parallel: boolean

`Private` `Readonly`defaultOptions

defaultOptions: PipelineOptions

Methods

run

run(overrideOptions?: PipelineOptions): Promise<OrchestratorResult>
Run all pipelines and return an aggregated OrchestratorResult.
Parameters
- OptionaloverrideOptions: PipelineOptions
  Options forwarded to every pipeline, merged on top of defaultOptions.
Returns Promise<OrchestratorResult>
- Defined in scripts/pipeline/orchestrator.ts:68

`Private`_runSingle

_runSingle(
pipeline: ContentPipeline,
options: PipelineOptions,
): Promise<PipelineResult>
Run a single pipeline, wrapping any unexpected throws in a failed result.
Parameters
- pipeline: ContentPipeline
- options: PipelineOptions
Returns Promise<PipelineResult>
- Defined in scripts/pipeline/orchestrator.ts:114

`Private`_aggregate

_aggregate(
results: Record<string, PipelineResult>,
totalDurationMs: number,
): OrchestratorResult
Aggregate individual pipeline results into a single orchestrator result.
Parameters
- results: Record<string, PipelineResult>
- totalDurationMs: number
Returns OrchestratorResult
- Defined in scripts/pipeline/orchestrator.ts:147