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 = None,
execution_queue_attributes = None,
execution_cluster_label = None,
plugin_overrides = None,
)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