1.16.16

flytekit.models.matchable_resource

Directory

Classes

Class Description
ClusterResourceAttributes
ExecutionClusterLabel
ExecutionQueueAttributes
MatchableResource
MatchingAttributes
PluginOverride
PluginOverrides

flytekit.models.matchable_resource.ClusterResourceAttributes

Parameters

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
is_empty None

Methods

Method Description
from_flyte_idl()
serialize_to_string()
short_string()
to_flyte_idl()

from_flyte_idl()

def from_flyte_idl(
    pb2_object,
)
Parameter Type Description
pb2_object

Returns: ClusterResourceAttributes

serialize_to_string()

def serialize_to_string()

short_string()

def short_string()

Returns: Text

to_flyte_idl()

def to_flyte_idl()

Returns: flyteidl.admin.matchable_resource_pb2.ClusterResourceAttributes

flytekit.models.matchable_resource.ExecutionClusterLabel

Parameters

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

Methods

Method Description
from_flyte_idl()
serialize_to_string()
short_string()
to_flyte_idl()

from_flyte_idl()

def from_flyte_idl(
    pb2_object,
)
Parameter Type Description
pb2_object

Returns: ExecutionClusterLabel

serialize_to_string()

def serialize_to_string()

short_string()

def short_string()

Returns: Text

to_flyte_idl()

def to_flyte_idl()

Returns: flyteidl.admin.matchable_resource_pb2.ExecutionClusterLabel

flytekit.models.matchable_resource.ExecutionQueueAttributes

Parameters

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

Methods

Method Description
from_flyte_idl()
serialize_to_string()
short_string()
to_flyte_idl()

from_flyte_idl()

def from_flyte_idl(
    pb2_object,
)
Parameter Type Description
pb2_object

Returns: ExecutionQueueAttributes

serialize_to_string()

def serialize_to_string()

short_string()

def short_string()

Returns: Text

to_flyte_idl()

def to_flyte_idl()

Returns: 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

Returns: Text

string_to_enum()

def string_to_enum(
    val,
)
Parameter Type Description
val

Returns: int

flytekit.models.matchable_resource.MatchingAttributes

Parameters

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).
execution_cluster_label None Label value to determine where the execution will be run.
execution_queue_attributes None Tags used for assigning execution queues for tasks.
is_empty None
plugin_overrides None Plugin implementation overrides for specific task types.

Methods

Method Description
from_flyte_idl()
serialize_to_string()
short_string()
to_flyte_idl()

from_flyte_idl()

def from_flyte_idl(
    pb2_object,
)
Parameter Type Description
pb2_object

Returns: MatchingAttributes

serialize_to_string()

def serialize_to_string()

short_string()

def short_string()

Returns: Text

to_flyte_idl()

def to_flyte_idl()

Returns: flyteidl.admin.matchable_resource_pb2.MatchingAttributes

flytekit.models.matchable_resource.PluginOverride

Parameters

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
plugin_id None
task_type None

Methods

Method Description
from_flyte_idl()
serialize_to_string()
short_string()
string_to_enum()
to_flyte_idl()

from_flyte_idl()

def from_flyte_idl(
    pb2_object,
)
Parameter Type Description
pb2_object

Returns: PluginOverride

serialize_to_string()

def serialize_to_string()

short_string()

def short_string()

Returns: Text

string_to_enum()

def string_to_enum(
    val,
)
Parameter Type Description
val

Returns: int

to_flyte_idl()

def to_flyte_idl()

Returns: flyteidl.admin.matchable_resource_pb2.PluginOverride

flytekit.models.matchable_resource.PluginOverrides

Parameters

class PluginOverrides(
    overrides,
)

Alternate plugin implementations for designated task types.

Parameter Type Description
overrides

Properties

Property Type Description
is_empty None
overrides None

Methods

Method Description
from_flyte_idl()
serialize_to_string()
short_string()
to_flyte_idl()

from_flyte_idl()

def from_flyte_idl(
    pb2_object,
)
Parameter Type Description
pb2_object

Returns: PluginOverrides

serialize_to_string()

def serialize_to_string()

short_string()

def short_string()

Returns: Text

to_flyte_idl()

def to_flyte_idl()

Returns: flyteidl.admin.matchable_resource_pb2.PluginOverrides