0.1.dev2192+g7c539c3.d20250403
flytekit.models.node_execution
Directory
Classes
| Class | Description |
|---|---|
DynamicWorkflowNodeMetadata |
|
NodeExecution |
|
NodeExecutionClosure |
|
TaskNodeMetadata |
|
WorkflowNodeMetadata |
flytekit.models.node_execution.DynamicWorkflowNodeMetadata
class DynamicWorkflowNodeMetadata(
id: flytekit.models.core.identifier.Identifier,
compiled_workflow: flytekit.models.core.compiler.CompiledWorkflowClosure,
)| Parameter | Type |
|---|---|
id |
flytekit.models.core.identifier.Identifier |
compiled_workflow |
flytekit.models.core.compiler.CompiledWorkflowClosure |
Methods
| Method | Description |
|---|---|
from_flyte_idl() |
|
serialize_to_string() |
|
short_string() |
:rtype: Text. |
to_flyte_idl() |
|
verbose_string() |
:rtype: Text. |
from_flyte_idl()
def from_flyte_idl(
p: flyteidl.admin.node_execution_pb2.DynamicWorkflowNodeMetadata,
) -> DynamicWorkflowNodeMetadata| Parameter | Type |
|---|---|
p |
flyteidl.admin.node_execution_pb2.DynamicWorkflowNodeMetadata |
serialize_to_string()
def serialize_to_string()short_string()
def short_string():rtype: Text
to_flyte_idl()
def to_flyte_idl()verbose_string()
def verbose_string():rtype: Text
Properties
| Property | Type | Description |
|---|---|---|
compiled_workflow |
||
id |
||
is_empty |
flytekit.models.node_execution.NodeExecution
class NodeExecution(
id,
input_uri,
closure,
metadata: flyteidl.admin.node_execution_pb2.NodeExecutionMetaData,
)| Parameter | Type |
|---|---|
id |
|
input_uri |
|
closure |
|
metadata |
flyteidl.admin.node_execution_pb2.NodeExecutionMetaData |
Methods
| Method | Description |
|---|---|
from_flyte_idl() |
|
serialize_to_string() |
|
short_string() |
:rtype: Text. |
to_flyte_idl() |
|
verbose_string() |
:rtype: Text. |
from_flyte_idl()
def from_flyte_idl(
p: flyteidl.admin.node_execution_pb2.NodeExecution,
) -> NodeExecution| Parameter | Type |
|---|---|
p |
flyteidl.admin.node_execution_pb2.NodeExecution |
serialize_to_string()
def serialize_to_string()short_string()
def short_string():rtype: Text
to_flyte_idl()
def to_flyte_idl()verbose_string()
def verbose_string():rtype: Text
Properties
| Property | Type | Description |
|---|---|---|
closure |
:rtype: NodeExecutionClosure |
|
id |
:rtype: flytekit.models.core.identifier.NodeExecutionIdentifier |
|
input_uri |
:rtype: Text |
|
is_empty |
||
metadata |
flytekit.models.node_execution.NodeExecutionClosure
class NodeExecutionClosure(
phase,
started_at,
duration,
output_uri,
deck_uri,
error,
workflow_node_metadata: typing.Optional[flytekit.models.node_execution.WorkflowNodeMetadata],
task_node_metadata: typing.Optional[flytekit.models.node_execution.TaskNodeMetadata],
created_at: typing.Optional[datetime.datetime],
updated_at: typing.Optional[datetime.datetime],
)| Parameter | Type |
|---|---|
phase |
|
started_at |
|
duration |
|
output_uri |
|
deck_uri |
|
error |
|
workflow_node_metadata |
typing.Optional[flytekit.models.node_execution.WorkflowNodeMetadata] |
task_node_metadata |
typing.Optional[flytekit.models.node_execution.TaskNodeMetadata] |
created_at |
typing.Optional[datetime.datetime] |
updated_at |
typing.Optional[datetime.datetime] |
Methods
| Method | Description |
|---|---|
from_flyte_idl() |
|
serialize_to_string() |
|
short_string() |
:rtype: Text. |
to_flyte_idl() |
:rtype: flyteidl. |
verbose_string() |
:rtype: Text. |
from_flyte_idl()
def from_flyte_idl(
p,
) -> e: NodeExecutionClosure| Parameter | Type |
|---|---|
p |
serialize_to_string()
def serialize_to_string()short_string()
def short_string():rtype: Text
to_flyte_idl()
def to_flyte_idl():rtype: flyteidl.admin.node_execution_pb2.NodeExecutionClosure
verbose_string()
def verbose_string():rtype: Text
Properties
| Property | Type | Description |
|---|---|---|
created_at |
||
deck_uri |
:rtype: str |
|
duration |
:rtype: datetime.timedelta |
|
error |
:rtype: flytekit.models.core.execution.ExecutionError |
|
is_empty |
||
output_uri |
:rtype: Text |
|
phase |
:rtype: int |
|
started_at |
:rtype: datetime.datetime |
|
target_metadata |
||
task_node_metadata |
||
updated_at |
||
workflow_node_metadata |
flytekit.models.node_execution.TaskNodeMetadata
class TaskNodeMetadata(
cache_status: int,
catalog_key: flytekit.models.core.catalog.CatalogMetadata,
)| Parameter | Type |
|---|---|
cache_status |
int |
catalog_key |
flytekit.models.core.catalog.CatalogMetadata |
Methods
| Method | Description |
|---|---|
from_flyte_idl() |
|
serialize_to_string() |
|
short_string() |
:rtype: Text. |
to_flyte_idl() |
|
verbose_string() |
:rtype: Text. |
from_flyte_idl()
def from_flyte_idl(
p: flyteidl.admin.node_execution_pb2.TaskNodeMetadata,
) -> TaskNodeMetadata| Parameter | Type |
|---|---|
p |
flyteidl.admin.node_execution_pb2.TaskNodeMetadata |
serialize_to_string()
def serialize_to_string()short_string()
def short_string():rtype: Text
to_flyte_idl()
def to_flyte_idl()verbose_string()
def verbose_string():rtype: Text
Properties
| Property | Type | Description |
|---|---|---|
cache_status |
||
catalog_key |
||
is_empty |
flytekit.models.node_execution.WorkflowNodeMetadata
class WorkflowNodeMetadata(
execution_id: flytekit.models.core.identifier.WorkflowExecutionIdentifier,
)| Parameter | Type |
|---|---|
execution_id |
flytekit.models.core.identifier.WorkflowExecutionIdentifier |
Methods
| Method | Description |
|---|---|
from_flyte_idl() |
|
serialize_to_string() |
|
short_string() |
:rtype: Text. |
to_flyte_idl() |
|
verbose_string() |
:rtype: Text. |
from_flyte_idl()
def from_flyte_idl(
p: flyteidl.admin.node_execution_pb2.WorkflowNodeMetadata,
) -> WorkflowNodeMetadata| Parameter | Type |
|---|---|
p |
flyteidl.admin.node_execution_pb2.WorkflowNodeMetadata |
serialize_to_string()
def serialize_to_string()short_string()
def short_string():rtype: Text
to_flyte_idl()
def to_flyte_idl()verbose_string()
def verbose_string():rtype: Text
Properties
| Property | Type | Description |
|---|---|---|
execution_id |
||
is_empty |