Skip to content

pipelineStore

const pipelineStore: AsyncLocalStorage<IPipelineContext<unknown, unknown>>

Defined in: packages/pipeline/src/constants/pipeline-context.constants.ts:16

Async-local store that propagates pipeline context across the async call chain. When a saga or nested CommandBus.execute() triggers a child handler, the child’s PipelineContext inherits the parent’s correlationId automatically.

Stores a reference to the live context object so child pipelines inherit the same immutable correlation ID.

Uses Node.js built-in AsyncLocalStorage — zero external dependencies.