0.1.dev2192+g7c539c3.d20250403
flytekit.models.admin.task_execution
Directory
Classes
| Class | Description |
|---|---|
TaskExecution |
|
TaskExecutionClosure |
flytekit.models.admin.task_execution.TaskExecution
class TaskExecution(
id,
input_uri,
closure,
is_parent,
)| Parameter | Type |
|---|---|
id |
|
input_uri |
|
closure |
|
is_parent |
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(
proto,
) -> e: TaskExecution| Parameter | Type |
|---|---|
proto |
serialize_to_string()
def serialize_to_string()short_string()
def short_string():rtype: Text
to_flyte_idl()
def to_flyte_idl():rtype: flyteidl.admin.task_execution_pb2.TaskExecution
verbose_string()
def verbose_string():rtype: Text
Properties
| Property | Type | Description |
|---|---|---|
closure |
:rtype: TaskExecutionClosure |
|
id |
:rtype: flytekit.models.core.identifier.TaskExecutionIdentifier |
|
input_uri |
:rtype: Text |
|
is_empty |
||
is_parent |
:rtype: bool |
flytekit.models.admin.task_execution.TaskExecutionClosure
class TaskExecutionClosure(
phase,
logs,
started_at,
duration,
created_at,
updated_at,
output_uri,
error,
metadata,
)| Parameter | Type |
|---|---|
phase |
|
logs |
|
started_at |
|
duration |
|
created_at |
|
updated_at |
|
output_uri |
|
error |
|
metadata |
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: TaskExecutionClosure| 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.task_execution_pb2.TaskExecutionClosure
verbose_string()
def verbose_string():rtype: Text
Properties
| Property | Type | Description |
|---|---|---|
created_at |
:rtype: datetime.datetime |
|
duration |
:rtype: datetime.timedelta |
|
error |
:rtype: flytekit.models.core.execution.ExecutionError |
|
is_empty |
||
logs |
:rtype: list[flytekit.models.core.execution.TaskLog] |
|
metadata |
:rtype: flytekit.models.event.TaskExecutionMetadata |
|
output_uri |
:rtype: Text |
|
phase |
Enum value from flytekit.models.core.execution.TaskExecutionPhase :rtype: flytekit.models.core.execution.TaskExecutionPhase |
|
started_at |
:rtype: datetime.datetime |
|
updated_at |
:rtype: datetime.datetime |