1.16.10
flytekit.models.core.identifier
Directory
Classes
| Class | Description |
|---|---|
Identifier |
|
NodeExecutionIdentifier |
|
ResourceType |
|
SignalIdentifier |
|
TaskExecutionIdentifier |
|
WorkflowExecutionIdentifier |
flytekit.models.core.identifier.Identifier
class Identifier(
resource_type,
project,
domain,
name,
version,
)| Parameter | Type | Description |
|---|---|---|
resource_type |
||
project |
||
domain |
||
name |
||
version |
Methods
| Method | Description |
|---|---|
from_flyte_idl() |
|
resource_type_name() |
|
serialize_to_string() |
|
short_string() |
:rtype: Text. |
to_flyte_idl() |
:rtype: flyteidl. |
from_flyte_idl()
def from_flyte_idl(
p,
)| Parameter | Type | Description |
|---|---|---|
p |
resource_type_name()
def resource_type_name()serialize_to_string()
def serialize_to_string()short_string()
def short_string():rtype: Text
to_flyte_idl()
def to_flyte_idl():rtype: flyteidl.core.identifier_pb2.Identifier
Properties
| Property | Type | Description |
|---|---|---|
domain |
:rtype: Text |
|
is_empty |
||
name |
:rtype: Text |
|
project |
:rtype: Text |
|
resource_type |
enum value from ResourceType :rtype: int |
|
version |
:rtype: Text |
flytekit.models.core.identifier.NodeExecutionIdentifier
class NodeExecutionIdentifier(
node_id,
execution_id,
)| Parameter | Type | Description |
|---|---|---|
node_id |
||
execution_id |
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(
p,
)| Parameter | Type | Description |
|---|---|---|
p |
serialize_to_string()
def serialize_to_string()short_string()
def short_string():rtype: Text
to_flyte_idl()
def to_flyte_idl():rtype: flyteidl.core.identifier_pb2.NodeExecutionIdentifier
Properties
| Property | Type | Description |
|---|---|---|
execution_id |
:rtype: WorkflowExecutionIdentifier |
|
is_empty |
||
node_id |
:rtype: Text |
flytekit.models.core.identifier.ResourceType
flytekit.models.core.identifier.SignalIdentifier
class SignalIdentifier(
signal_id: str,
execution_id: flytekit.models.core.identifier.WorkflowExecutionIdentifier,
)| Parameter | Type | Description |
|---|---|---|
signal_id |
str |
User provided name for the gate node. |
execution_id |
flytekit.models.core.identifier.WorkflowExecutionIdentifier |
The workflow execution id this signal is for. |
Methods
| Method | Description |
|---|---|
from_flyte_idl() |
|
serialize_to_string() |
|
short_string() |
:rtype: Text. |
to_flyte_idl() |
from_flyte_idl()
def from_flyte_idl(
proto: flyteidl.core.identifier_pb2.SignalIdentifier,
) -> SignalIdentifier| Parameter | Type | Description |
|---|---|---|
proto |
flyteidl.core.identifier_pb2.SignalIdentifier |
serialize_to_string()
def serialize_to_string()short_string()
def short_string():rtype: Text
to_flyte_idl()
def to_flyte_idl()Properties
| Property | Type | Description |
|---|---|---|
execution_id |
||
is_empty |
||
signal_id |
flytekit.models.core.identifier.TaskExecutionIdentifier
class TaskExecutionIdentifier(
task_id,
node_execution_id,
retry_attempt,
)| Parameter | Type | Description |
|---|---|---|
task_id |
||
node_execution_id |
||
retry_attempt |
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(
proto,
)| Parameter | Type | Description |
|---|---|---|
proto |
serialize_to_string()
def serialize_to_string()short_string()
def short_string():rtype: Text
to_flyte_idl()
def to_flyte_idl():rtype: flyteidl.core.identifier_pb2.TaskExecutionIdentifier
Properties
| Property | Type | Description |
|---|---|---|
is_empty |
||
node_execution_id |
:rtype: NodeExecutionIdentifier |
|
retry_attempt |
:rtype: int |
|
task_id |
:rtype: Identifier |
flytekit.models.core.identifier.WorkflowExecutionIdentifier
class WorkflowExecutionIdentifier(
project,
domain,
name,
)| Parameter | Type | Description |
|---|---|---|
project |
||
domain |
||
name |
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(
p,
)| Parameter | Type | Description |
|---|---|---|
p |
serialize_to_string()
def serialize_to_string()short_string()
def short_string():rtype: Text
to_flyte_idl()
def to_flyte_idl():rtype: flyteidl.core.identifier_pb2.WorkflowExecutionIdentifier
Properties
| Property | Type | Description |
|---|---|---|
domain |
:rtype: Text |
|
is_empty |
||
name |
:rtype: Text |
|
project |
:rtype: Text |