flytekit.models.matchable_resource

Directory

Classes

flytekit.models.matchable_resource.ClusterResourceAttributes

def 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,
):

serialize_to_string()

def serialize_to_string()

short_string()

def short_string()

to_flyte_idl()

def to_flyte_idl()

verbose_string()

def verbose_string()

Properties

flytekit.models.matchable_resource.ExecutionClusterLabel

def ExecutionClusterLabel(
    value,
):

Label value to determine where the execution will be run

Methods

from_flyte_idl()

def from_flyte_idl(
    pb2_object,
):

serialize_to_string()

def serialize_to_string()

short_string()

def short_string()

to_flyte_idl()

def to_flyte_idl()

verbose_string()

def verbose_string()

Properties

flytekit.models.matchable_resource.ExecutionQueueAttributes

def 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,
):

serialize_to_string()

def serialize_to_string()

short_string()

def short_string()

to_flyte_idl()

def to_flyte_idl()

verbose_string()

def verbose_string()

Properties

flytekit.models.matchable_resource.MatchableResource

Methods

enum_to_string()

def enum_to_string(
    val,
):

string_to_enum()

def string_to_enum(
    val,
):

flytekit.models.matchable_resource.MatchingAttributes

def 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,
):

serialize_to_string()

def serialize_to_string()

short_string()

def short_string()

to_flyte_idl()

def to_flyte_idl()

verbose_string()

def verbose_string()

Properties

flytekit.models.matchable_resource.PluginOverride

def 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,
):

serialize_to_string()

def serialize_to_string()

short_string()

def short_string()

string_to_enum()

def string_to_enum(
    val,
):

to_flyte_idl()

def to_flyte_idl()

verbose_string()

def verbose_string()

Properties

flytekit.models.matchable_resource.PluginOverrides

def PluginOverrides(
    overrides,
):

Alternate plugin implementations for designated task types.

Methods

from_flyte_idl()

def from_flyte_idl(
    pb2_object,
):

serialize_to_string()

def serialize_to_string()

short_string()

def short_string()

to_flyte_idl()

def to_flyte_idl()

verbose_string()

def verbose_string()

Properties