ConnectorEnvironment

Configure a connector environment for custom Flyte connectors.

Attributes

Attribute	Type	Description
type	str = connector	The identifier for the environment type, defaulting to "connector" to specify a custom Flyte connector environment.
port	`int	Port` = Port(port=8080, name="h2c")

---

Constructor

Signature

def ConnectorEnvironment(
    type: str = "connector",
    port: int | Port = Port(port=8080, name="h2c")
) -> null

Parameters

Name	Type	Description
type	str = "connector"	The environment type identifier, defaults to 'connector'.
port	`int	Port` = Port(port=8080, name="h2c")

---

Methods

---

container_args()

def container_args(self, serialize_context: SerializationContext) -> List[str]: ...

Generates the command-line arguments for the connector container, including port configurations and the list of Python modules to load.

Parameters

Name	Type	Description
serialize_context	SerializationContext	The context object containing settings and state for the current serialization pass.

Returns

Type	Description
List[str]	A list of string arguments used to start the connector process, such as port flags and module names.

---

container_cmd()

def container_cmd(
        self, serialize_context: SerializationContext, parameter_overrides: list[Parameter] | None = None
    ) -> List[str]: ...

Determines the primary command to execute within the container, prioritizing explicit overrides before falling back to parent defaults.

Parameters

Name	Type	Description
serialize_context	SerializationContext	The context object containing settings and state for the current serialization pass.
parameter_overrides	`list[Parameter]	None`

Returns

Type	Description
List[str]	The executable command split into a list of strings suitable for container execution.

---