RemoteConnectorWorker

Register worker-owned Definitions and execute one Connector binding.

Functions

constructor__init__(*, client, registry) -> None

paramclientPowerContextClient

paramregistrySourceDefinitionRegistry

Returns

None

funcrun(connector, binding) -> ConnectorRunResult

paramconnectorConnector

parambindingConnectorBinding

Returns

powercontext.sources.ConnectorRunResult

_RemoteConnectorSourceSink class