flytekit.models.matchable_resource

Directory

Classes

flytekit.models.matchable_resource.ClusterResourceAttributes

class ClusterResourceAttributes(
    attributes,
)

Custom resource attributes which will be applied in cluster resource creation (e.g. quotas). Dict keys are the case-sensitive names of variables in templatized resource files. Dict values should be the custom values which get substituted during resource creation.

Methods

from_flyte_idl()

def from_flyte_idl(
    pb2_object,
) -> e: ClusterResourceAttributes

serialize_to_string()

def serialize_to_string()

short_string()

def short_string()

:rtype: Text

to_flyte_idl()

def to_flyte_idl()

:rtype: flyteidl.admin.matchable_resource_pb2.ClusterResourceAttributes

verbose_string()

def verbose_string()

:rtype: Text

Properties

flytekit.models.matchable_resource.ExecutionClusterLabel

class ExecutionClusterLabel(
    value,
)

Label value to determine where the execution will be run

Methods

from_flyte_idl()

def from_flyte_idl(
    pb2_object,
) -> e: ExecutionClusterLabel

serialize_to_string()

def serialize_to_string()

short_string()

def short_string()

:rtype: Text

to_flyte_idl()

def to_flyte_idl()

:rtype: flyteidl.admin.matchable_resource_pb2.ExecutionClusterLabel

verbose_string()

def verbose_string()

:rtype: Text

Properties

flytekit.models.matchable_resource.ExecutionQueueAttributes

class ExecutionQueueAttributes(
    tags,
)

Tags used for assigning execution queues for tasks matching a project, domain and optionally, workflow.

Methods

from_flyte_idl()

def from_flyte_idl(
    pb2_object,
) -> e: ExecutionQueueAttributes

serialize_to_string()

def serialize_to_string()

short_string()

def short_string()

:rtype: Text

to_flyte_idl()

def to_flyte_idl()

:rtype: flyteidl.admin.matchable_resource_pb2.ExecutionQueueAttributes

verbose_string()

def verbose_string()

:rtype: Text

Properties

flytekit.models.matchable_resource.MatchableResource

Methods

enum_to_string()

def enum_to_string(
    val,
) -> e: Text

string_to_enum()

def string_to_enum(
    val,
) -> e: int

flytekit.models.matchable_resource.MatchingAttributes

class MatchingAttributes(
    cluster_resource_attributes,
    execution_queue_attributes,
    execution_cluster_label,
    plugin_overrides,
)

At most one target from cluster_resource_attributes, execution_queue_attributes or execution_cluster_label can be set.

Methods

from_flyte_idl()

def from_flyte_idl(
    pb2_object,
) -> e: MatchingAttributes

serialize_to_string()

def serialize_to_string()

short_string()

def short_string()

:rtype: Text

to_flyte_idl()

def to_flyte_idl()

:rtype: flyteidl.admin.matchable_resource_pb2.MatchingAttributes

verbose_string()

def verbose_string()

:rtype: Text

Properties

flytekit.models.matchable_resource.PluginOverride

class PluginOverride(
    task_type,
    plugin_id,
    missing_plugin_behavior,
)

Alternate plugin implementations requested for a specific task type.

Methods

from_flyte_idl()

def from_flyte_idl(
    pb2_object,
) -> e: PluginOverride

serialize_to_string()

def serialize_to_string()

short_string()

def short_string()

:rtype: Text

string_to_enum()

def string_to_enum(
    val,
) -> e: int

to_flyte_idl()

def to_flyte_idl()

:rtype: flyteidl.admin.matchable_resource_pb2.PluginOverride

verbose_string()

def verbose_string()

:rtype: Text

Properties

flytekit.models.matchable_resource.PluginOverrides

class PluginOverrides(
    overrides,
)

Alternate plugin implementations for designated task types.

Methods

from_flyte_idl()

def from_flyte_idl(
    pb2_object,
) -> e: PluginOverrides

serialize_to_string()

def serialize_to_string()

short_string()

def short_string()

:rtype: Text

to_flyte_idl()

def to_flyte_idl()

:rtype: flyteidl.admin.matchable_resource_pb2.PluginOverrides

verbose_string()

def verbose_string()

:rtype: Text

Properties