StageTrigger

classView source ↗

class StageTrigger(start: datetime | None = None, end: datetime | None = None)

Bases: ABC

Categories: trigger

Defines the parameters for a stage trigger of a publisher. The source plugin being used must support stage trigger functionality.

Parameters

parameter

start

datetime for the stage trigger to start working.

parameter

end

datetime for the stage trigger to stop working.

Properties

property

enddatetime | None

property

outdict[int, str] | None

Returns a mapping of positional index to table name for the outputs produced by this trigger, or None when the StageTrigger implementation only supports generating a single table.

property

startdatetime | None

Methods

method

View source ↗

run

def run(ctx: StageTriggerContext) -> StageTriggerStatus

Continuously runs the stage trigger logic using the received context to trigger and monitor executions. SUCCESS if the StageTrigger.end datetime is reached. exit with 0. ERROR if any issue stops it from working or recovering. exit with 1. STOPPED upon a signal. exit with 0.