flytekitplugins.mmcloud.utils

Directory

Methods

Method	Description
`async_check_output()`	This behaves similarly to subprocess.
`flyte_to_mmcloud_resources()`	Map Flyte (K8s) resources to MMCloud resources.
`mmcloud_status_to_flyte_phase()`	Map MMCloud status to Flyte phase.

Variables

Property	Type	Description
`MMCLOUD_STATUS_TO_FLYTE_PHASE`	`dict`
`PIPE`	`int`
`ROUND_CEILING`	`str`

Methods

async_check_output()

        
    
def async_check_output(
    *args,
    **kwargs,
)

This behaves similarly to subprocess.check_output().

Parameter	Type	Description
`*args`
`**kwargs`

flyte_to_mmcloud_resources()

        
    
def flyte_to_mmcloud_resources(
    requests: typing.Optional[flytekit.core.resources.Resources] = None,
    limits: typing.Optional[flytekit.core.resources.Resources] = None,
) -> typing.Tuple[int, int, int, int]

Map Flyte (K8s) resources to MMCloud resources.

Parameter	Type	Description
`requests`	`typing.Optional[flytekit.core.resources.Resources]`
`limits`	`typing.Optional[flytekit.core.resources.Resources]`

mmcloud_status_to_flyte_phase()

        
    
def mmcloud_status_to_flyte_phase(
    status: str,
) -> google.protobuf.internal.enum_type_wrapper.EnumTypeWrapper

Map MMCloud status to Flyte phase.

Parameter	Type	Description
`status`	`str`