Skip to main content

ConnectorEnvironment

Configure a connector environment for custom Flyte connectors.

Attributes

AttributeTypeDescription
typestr = "connector"This attribute stores the type of the environment, which is fixed as "connector" for connector environments.
port`intPort` = Port(port=8080, name="h2c")

Methods


container_args()

@classmethod
def container_args(
serialize_context: [SerializationContext](../../../models/serializationcontext.md?sid=flyte_models_serializationcontext)
) - > List[str]

Builds the command-line arguments for the connector container. This method constructs arguments based on the configured port and included modules, or defers to the parent class if custom arguments are provided.

Parameters

NameTypeDescription
serialize_context[SerializationContext](../../../models/serializationcontext.md?sid=flyte_models_serializationcontext)The serialization context, which provides information needed for serialization.

Returns

TypeDescription
List[str]A list of strings representing the command-line arguments for the container.

container_cmd()

@classmethod
def container_cmd(
serialize_context: [SerializationContext](../../../models/serializationcontext.md?sid=flyte_models_serializationcontext),
parameter_overrides: list[[Parameter](../../parameter/parameter.md?sid=flyte_app__parameter_parameter)]| None = None
) - > List[str]

Determines the command to execute within the connector container. This method returns the command as a list of strings, either by splitting a string command, using a provided list, or falling back to the parent class's default command.

Parameters

NameTypeDescription
serialize_context[SerializationContext](../../../models/serializationcontext.md?sid=flyte_models_serializationcontext)The serialization context, which provides information needed for serialization.
parameter_overrides`list[Parameter]None` = None

Returns

TypeDescription
List[str]A list of strings representing the command to be executed in the container.