1.16.14

flytekit.models.matchable_resource

Directory

Classes

Class Description
ClusterResourceAttributes
ExecutionClusterLabel
ExecutionQueueAttributes
MatchableResource
MatchingAttributes
PluginOverride
PluginOverrides

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.

Parameter Type Description
attributes

Properties

Property Type Description
attributes None Custom resource attributes which will be applied in cluster resource management :rtype: dict[Text, Text]
is_empty None

Methods

Method Description
from_flyte_idl()
serialize_to_string()
short_string() :rtype: Text.
to_flyte_idl() :rtype: flyteidl.

from_flyte_idl()

def from_flyte_idl(
    pb2_object,
)
Parameter Type Description
pb2_object

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

flytekit.models.matchable_resource.ExecutionClusterLabel

class ExecutionClusterLabel(
    value,
)

Label value to determine where the execution will be run

Parameter Type Description
value

Properties

Property Type Description
is_empty None
value None :rtype: Text

Methods

Method Description
from_flyte_idl()
serialize_to_string()
short_string() :rtype: Text.
to_flyte_idl() :rtype: flyteidl.

from_flyte_idl()

def from_flyte_idl(
    pb2_object,
)
Parameter Type Description
pb2_object

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

flytekit.models.matchable_resource.ExecutionQueueAttributes

class ExecutionQueueAttributes(
    tags,
)

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

Parameter Type Description
tags

Properties

Property Type Description
is_empty None
tags None :rtype: list[Text]

Methods

Method Description
from_flyte_idl()
serialize_to_string()
short_string() :rtype: Text.
to_flyte_idl() :rtype: flyteidl.

from_flyte_idl()

def from_flyte_idl(
    pb2_object,
)
Parameter Type Description
pb2_object

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

flytekit.models.matchable_resource.MatchableResource

Methods

Method Description
enum_to_string()
string_to_enum()

enum_to_string()

def enum_to_string(
    val,
)
Parameter Type Description
val

string_to_enum()

def string_to_enum(
    val,
)
Parameter Type Description
val

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.

Parameter Type Description
cluster_resource_attributes
execution_queue_attributes
execution_cluster_label
plugin_overrides

Properties

Property Type Description
cluster_resource_attributes None Custom resource attributes which will be applied in cluster resource creation (e.g. quotas). :rtype: ClusterResourceAttributes
execution_cluster_label None Label value to determine where the execution will be run. :rtype: ExecutionClusterLabel
execution_queue_attributes None Tags used for assigning execution queues for tasks. :rtype: ExecutionQueueAttributes
is_empty None
plugin_overrides None Plugin implementation overrides for specific task types. :rtype: PluginOverrides

Methods

Method Description
from_flyte_idl()
serialize_to_string()
short_string() :rtype: Text.
to_flyte_idl() :rtype: flyteidl.

from_flyte_idl()

def from_flyte_idl(
    pb2_object,
)
Parameter Type Description
pb2_object

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

flytekit.models.matchable_resource.PluginOverride

class PluginOverride(
    task_type,
    plugin_id,
    missing_plugin_behavior,
)

Alternate plugin implementations requested for a specific task type.

Parameter Type Description
task_type
plugin_id
missing_plugin_behavior

Properties

Property Type Description
is_empty None
missing_plugin_behavior None :rtype: int
plugin_id None :rtype: list[Text]
task_type None :rtype: Text

Methods

Method Description
from_flyte_idl()
serialize_to_string()
short_string() :rtype: Text.
string_to_enum()
to_flyte_idl() :rtype: flyteidl.

from_flyte_idl()

def from_flyte_idl(
    pb2_object,
)
Parameter Type Description
pb2_object

serialize_to_string()

def serialize_to_string()

short_string()

def short_string()

:rtype: Text

string_to_enum()

def string_to_enum(
    val,
)
Parameter Type Description
val

to_flyte_idl()

def to_flyte_idl()

:rtype: flyteidl.admin.matchable_resource_pb2.PluginOverride

flytekit.models.matchable_resource.PluginOverrides

class PluginOverrides(
    overrides,
)

Alternate plugin implementations for designated task types.

Parameter Type Description
overrides

Properties

Property Type Description
is_empty None
overrides None :rtype: list[PluginOverride]

Methods

Method Description
from_flyte_idl()
serialize_to_string()
short_string() :rtype: Text.
to_flyte_idl() :rtype: flyteidl.

from_flyte_idl()

def from_flyte_idl(
    pb2_object,
)
Parameter Type Description
pb2_object

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