Member Junction
    Preparing search index...

    Class BasePipelineStageAbstract

    A registered unit of pipeline work: one working record in, one outcome out. Adding a stage is writing a class and registering it — never editing a list.

    Cold start is the normal case: in production a stage gets a record hydrated moments ago, with no other stage having run in the same call, so a missing optional field is a legitimate input.

    @RegisterClass(BasePipelineStage, 'Extract')
    export class ExtractStage extends BasePipelineStage {
        public readonly Name = 'Extract';
        public readonly Entity: WorkingRecordEntity = 'Content Item';
        public readonly StatusField = 'ExtractionStatus';
        public async Run(record: WorkingRecord, context: StageContext): Promise<StageOutcome> { ... }
    }

    Hierarchy (View Summary)

    Index

    Constructors

    constructor

    Properties

    Entity Name StatusField

    Accessors

    CompleteStatus Declaration

    Methods

    Finalize? Run StatusForOutcome Resolve

    Constructors

    Properties

    Entity: WorkingRecordEntity

    The entity this stage runs over.

    Name: string

    The registered name; must match the @RegisterClass key.

    StatusField: string

    The status column the committer advances and a Record Process's filter reads (e.g. ExtractionStatus). null for Discover, which walks every source selected by the Record Process filter rather than advancing a status.

    Accessors

    Methods

    Settings

    Member Visibility

    On This Page

    Constructors
    Properties
    Accessors
    Methods