fastrag.ingestion.logger.base

Logger: the base class for a pipeline event stream consumer.

docs/specification/logging.md: a logger is a sink for a Pipeline’s event stream. It must never alter what the pipeline produces or how it handles errors — it only observes.

Classes

Logger(pipeline)

Base class for components that consume a pipeline's event stream.

class fastrag.ingestion.logger.base.Logger(pipeline)

Bases: ABC

Base class for components that consume a pipeline’s event stream.

A Logger is associated with one Pipeline at construction and does nothing until run() is awaited — matching every PipelineStep’s own “nothing happens at construction” contract.

Parameters:

pipeline (Pipeline)

pipeline: Pipeline

abstractmethod async run()

Consume and process every event from pipeline.

Implementations iterate self.pipeline (async for event in self.pipeline:), which both drives the pipeline’s root step to completion and yields each event as it is emitted — this is also what propagates a step failure out of run(), exactly as it does out of run(), under policy.on_error == "raise".

Return type:

None