2.5.16
ConnectorRegistry
Package: flyte.connectors
This is the registry for all connectors. The connector service will look up the connector registry based on the task type and version.
Methods
| Method | Description |
|---|---|
get_connector() |
|
register() |
get_connector()
def get_connector(
task_type_name: str,
task_type_version: int,
) -> AsyncConnector[Any]| Parameter | Type | Description |
|---|---|---|
task_type_name |
str |
|
task_type_version |
int |
register()
def register(
connector: flyte.connectors._connector.AsyncConnector[typing.Any],
override: bool,
)| Parameter | Type | Description |
|---|---|---|
connector |
flyte.connectors._connector.AsyncConnector[typing.Any] |
|
override |
bool |