0.0.0+develop

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
`args`	`*args`
`kwargs`	`**kwargs`

flyte_to_mmcloud_resources()

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

Map Flyte (K8s) resources to MMCloud resources.

Parameter	Type
`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 object at 0x121406390>

Map MMCloud status to Flyte phase.

Parameter	Type
`status`	`str`