_RemoteConnectorSourceSink

Resolve and project Definition-native values inside the worker.

Functions

constructor__init__(*, client, registry) -> None

paramclientPowerContextClient

paramregistrySourceDefinitionRegistry

Returns

None

funcsubmit(binding, item_id, definition_name, value) -> SourceRef

parambindingConnectorBinding

paramitem_idstr

paramdefinition_namestr

paramvalueobject

Returns

powercontext.sources.SourceRef

_RemoteConnectorCheckpointStore class