flytekit.models.matchable_resource
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 |
|
|
| Property |
Type |
Description |
attributes |
None |
Custom resource attributes which will be applied in cluster resource management |
is_empty |
None |
|
def from_flyte_idl(
pb2_object,
)
| Parameter |
Type |
Description |
pb2_object |
|
|
Returns: ClusterResourceAttributes
def serialize_to_string()
Returns: Text
Returns: flyteidl.admin.matchable_resource_pb2.ClusterResourceAttributes
class ExecutionClusterLabel(
value,
)
Label value to determine where the execution will be run
| Parameter |
Type |
Description |
value |
|
|
| Property |
Type |
Description |
is_empty |
None |
|
value |
None |
|
def from_flyte_idl(
pb2_object,
)
| Parameter |
Type |
Description |
pb2_object |
|
|
Returns: ExecutionClusterLabel
def serialize_to_string()
Returns: Text
Returns: flyteidl.admin.matchable_resource_pb2.ExecutionClusterLabel
class ExecutionQueueAttributes(
tags,
)
Tags used for assigning execution queues for tasks matching a project, domain and optionally, workflow.
| Parameter |
Type |
Description |
tags |
|
|
| Property |
Type |
Description |
is_empty |
None |
|
tags |
None |
|
def from_flyte_idl(
pb2_object,
)
| Parameter |
Type |
Description |
pb2_object |
|
|
Returns: ExecutionQueueAttributes
def serialize_to_string()
Returns: Text
Returns: flyteidl.admin.matchable_resource_pb2.ExecutionQueueAttributes
def enum_to_string(
val,
)
| Parameter |
Type |
Description |
val |
|
|
Returns: Text
def string_to_enum(
val,
)
| Parameter |
Type |
Description |
val |
|
|
Returns: int
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 |
|
|
| 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. |
def from_flyte_idl(
pb2_object,
)
| Parameter |
Type |
Description |
pb2_object |
|
|
Returns: MatchingAttributes
def serialize_to_string()
Returns: Text
Returns: flyteidl.admin.matchable_resource_pb2.MatchingAttributes
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 |
|
|
| Property |
Type |
Description |
is_empty |
None |
|
missing_plugin_behavior |
None |
|
plugin_id |
None |
|
task_type |
None |
|
def from_flyte_idl(
pb2_object,
)
| Parameter |
Type |
Description |
pb2_object |
|
|
Returns: PluginOverride
def serialize_to_string()
Returns: Text
def string_to_enum(
val,
)
| Parameter |
Type |
Description |
val |
|
|
Returns: int
Returns: flyteidl.admin.matchable_resource_pb2.PluginOverride
class PluginOverrides(
overrides,
)
Alternate plugin implementations for designated task types.
| Parameter |
Type |
Description |
overrides |
|
|
| Property |
Type |
Description |
is_empty |
None |
|
overrides |
None |
|
def from_flyte_idl(
pb2_object,
)
| Parameter |
Type |
Description |
pb2_object |
|
|
Returns: PluginOverrides
def serialize_to_string()
Returns: Text
Returns: flyteidl.admin.matchable_resource_pb2.PluginOverrides