Powercontextsourcesconnectors

ConnectorRunSession

Constrain one Connector run to declared Definitions and visible outcomes.

Attributes

attributebinding
= binding
attributecheckpoint
= checkpoint
attributeoutcomestuple[ConnectorItemOutcome, ...]

Functions

constructor__init__(*, binding, checkpoint, source_definitions, sink) -> None
parambindingConnectorBinding
paramcheckpointJsonValue | None
paramsource_definitionsfrozenset[str]
paramsinkConnectorSourceSink

Returns

None
funcsubmit(item_id, definition_name, value) -> ConnectorItemOutcome

Submit one item and record its durable Source reference exactly once.

paramitem_idstr
paramdefinition_namestr
paramvalueobject

Returns

powercontext.sources.connectors.ConnectorItemOutcome
funcreject(item_id, definition_name, detail) -> ConnectorItemOutcome

Record one provider item that cannot satisfy its Source Definition.

paramitem_idstr
paramdefinition_namestr
paramdetailstr

Returns

powercontext.sources.connectors.ConnectorItemOutcome
funcfail(item_id, definition_name, detail) -> ConnectorItemOutcome

Record one provider item that could not be acquired safely.

paramitem_idstr
paramdefinition_namestr
paramdetailstr

Returns

powercontext.sources.connectors.ConnectorItemOutcome
func_record_provider_outcome(item_id, definition_name, status, detail) -> ConnectorItemOutcome
paramitem_idstr
paramdefinition_namestr
paramstatusConnectorSubmissionStatus
paramdetailstr

Returns

powercontext.sources.connectors.ConnectorItemOutcome
func_claim_item(item_id, definition_name) -> None
paramitem_idstr
paramdefinition_namestr

Returns

None

ConnectorRunResult class

Previous Page

ConnectorRunStatus class

Next Page

On this page

AttributesFunctions