Pipeline

domain.enrichment.entity.pipeline

Summary

Loader for the entity enrichment pipeline.

Compiles the packaged pipeline.yaml plus the patterns/*.yaml registries into a cached dagpipe pipeline, wiring every registry-aware node with its registry and node config.

Classes

Functions

get_entity_pipeline

get_entity_pipeline()

Return the lazily cached entity pipeline.

Builds (once) and reuses the pipeline across calls.

Returns:

Type	Description
	The cached entity pipeline instance.

load

load() -> Pipeline

Load and wire the entity enrichment pipeline.

Reads the packaged pipeline.yaml, builds the pipeline graph, and installs the merged pattern registry and per-node config onto each node that supports it.

Returns:

Name	Type	Description
Pipeline	Pipeline	The wired dagpipe pipeline.

Raises:

Type	Description
FileNotFoundError	If the packaged pipeline.yaml is missing.