flytekit.remote.executions.FlyteTaskExecution#

class flytekit.remote.executions.FlyteTaskExecution(*args, **kwargs)[source]#

A class encapsulating a task execution being run on a Flyte remote backend.

Parameters

  • id (flytekit.models.core.identifier.TaskExecutionIdentifier) –

  • input_uri (Text) –

  • closure (TaskExecutionClosure) –

  • is_parent (bool) –

Methods

classmethod from_flyte_idl(proto)#
Parameters

proto (flyteidl.admin.task_execution_pb2.TaskExecution) –

Return type

TaskExecution

classmethod promote_from_model(base_model)[source]#
Parameters

base_model (flytekit.models.admin.task_execution.TaskExecution) –

Return type

flytekit.remote.executions.FlyteTaskExecution

serialize_to_string()#
Return type

str

short_string()#
Return type

Text

to_flyte_idl()#
Return type

flyteidl.admin.task_execution_pb2.TaskExecution

verbose_string()#
Return type

Text

Attributes

closure#

TaskExecutionClosure

Type

rtype

error#

If execution is in progress, raise an exception. Otherwise, return None if no error was present upon reaching completion.

id#

flytekit.models.core.identifier.TaskExecutionIdentifier

Type

rtype

input_uri#

Text

Type

rtype

inputs#
is_done#

Whether or not the execution is complete.

is_empty#
is_parent#

bool

Type

rtype

outputs#

Returns the outputs LiteralsResolver to the execution :raises: FlyteAssertion error if execution is in progress or execution ended in error.

Type

return

task#