ConnectorLifecycle

Run Connectors while enforcing durable checkpoint ordering.

Functions

constructor__init__(*, sink, checkpoints) -> None

paramsinkConnectorSourceSink

paramcheckpointsConnectorCheckpointStore

Returns

None

funcrun(connector, binding) -> ConnectorRunResult

paramconnectorConnector

parambindingConnectorBinding

Returns

powercontext.sources.connectors.ConnectorRunResult

ConnectorItemOutcome class