0.1.dev2184+g1e0cbe7.d20250401
flytekit.extend.backend.utils
Directory
Methods
Methods
convert_to_flyte_phase()
def convert_to_flyte_phase(
state: str,
) -> <google.protobuf.internal.enum_type_wrapper.EnumTypeWrapper object at 0x10758c3d0>
Convert the state from the connector to the phase in flyte.
get_agent_secret()
def get_agent_secret(
secret_key: str,
) -> str
Parameter |
Type |
secret_key |
str |
get_connector_secret()
def get_connector_secret(
secret_key: str,
) -> str
Parameter |
Type |
secret_key |
str |
is_terminal_phase()
def is_terminal_phase(
phase: <google.protobuf.internal.enum_type_wrapper.EnumTypeWrapper object at 0x10758c3d0>,
) -> bool
Return true if the phase is terminal.
Parameter |
Type |
phase |
<google.protobuf.internal.enum_type_wrapper.EnumTypeWrapper object at 0x10758c3d0> |
mirror_async_methods()
def mirror_async_methods(
func: typing.Callable,
kwargs,
) -> typing.Coroutine
Parameter |
Type |
func |
typing.Callable |
kwargs |
**kwargs |
render_task_template()
def render_task_template(
tt: flytekit.models.task.TaskTemplate,
file_prefix: str,
) -> flytekit.models.task.TaskTemplate
Parameter |
Type |
tt |
flytekit.models.task.TaskTemplate |
file_prefix |
str |