1.16.14

flytekit.remote.executions

Directory

Classes

Class Description
FlyteNodeExecution A class encapsulating a node execution being run on a Flyte remote backend.
FlyteTaskExecution A class encapsulating a task execution being run on a Flyte remote backend.
FlyteWorkflowExecution A class encapsulating a workflow execution being run on a Flyte remote backend.
RemoteExecutionBase

flytekit.remote.executions.FlyteNodeExecution

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

class FlyteNodeExecution(
    args,
    kwargs,
)
Parameter Type Description
args *args
kwargs **kwargs

Properties

Property Type Description
closure None :rtype: NodeExecutionClosure
error None If execution is in progress, raise an exception. Otherwise, return None if no error was present upon reaching completion.
executions None
id None :rtype: flytekit.models.core.identifier.NodeExecutionIdentifier
input_uri None :rtype: Text
inputs None
interface None Return the interface of the task or subworkflow associated with this node execution.
is_done None Whether or not the execution is complete.
is_empty None
metadata None
outputs None :return: Returns the outputs LiteralsResolver to the execution :raises: FlyteAssertion error if execution is in progress or execution ended in error.
subworkflow_node_executions None This returns underlying node executions in instances where the current node execution is a parent node. This happens when it’s either a static or dynamic subworkflow.
task_executions None
workflow_executions None

Methods

Method Description
from_flyte_idl()
promote_from_model()
serialize_to_string()
short_string() :rtype: Text.
to_flyte_idl()

from_flyte_idl() 

def from_flyte_idl(
    p: flyteidl.admin.node_execution_pb2.NodeExecution,
) -> NodeExecution
Parameter Type Description
p flyteidl.admin.node_execution_pb2.NodeExecution

promote_from_model() 

def promote_from_model(
    base_model: node_execution_models.NodeExecution,
) -> 'FlyteNodeExecution'
Parameter Type Description
base_model node_execution_models.NodeExecution

serialize_to_string() 

def serialize_to_string()

short_string() 

def short_string()

:rtype: Text

to_flyte_idl() 

def to_flyte_idl()

flytekit.remote.executions.FlyteTaskExecution

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

class FlyteTaskExecution(
    args,
    kwargs,
)
Parameter Type Description
args *args
kwargs **kwargs

Properties

Property Type Description
closure None :rtype: TaskExecutionClosure
error None If execution is in progress, raise an exception. Otherwise, return None if no error was present upon reaching completion.
id None :rtype: flytekit.models.core.identifier.TaskExecutionIdentifier
input_uri None :rtype: Text
inputs None
is_done None Whether or not the execution is complete.
is_empty None
is_parent None :rtype: bool
outputs None :return: Returns the outputs LiteralsResolver to the execution :raises: FlyteAssertion error if execution is in progress or execution ended in error.
task None

Methods

Method Description
from_flyte_idl()
promote_from_model()
serialize_to_string()
short_string() :rtype: Text.
to_flyte_idl() :rtype: flyteidl.

from_flyte_idl() 

def from_flyte_idl(
    proto,
)
Parameter Type Description
proto

promote_from_model() 

def promote_from_model(
    base_model: admin_task_execution_models.TaskExecution,
) -> 'FlyteTaskExecution'
Parameter Type Description
base_model admin_task_execution_models.TaskExecution

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

flytekit.remote.executions.FlyteWorkflowExecution

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

class FlyteWorkflowExecution(
    type_hints: Optional[Dict[str, typing.Type]],
    remote: Optional['FlyteRemote'],
    args,
    kwargs,
)
Parameter Type Description
type_hints Optional[Dict[str, typing.Type]]
remote Optional['FlyteRemote']
args *args
kwargs **kwargs

Properties

Property Type Description
closure None :rtype: ExecutionClosure
error None If execution is in progress, raise an exception. Otherwise, return None if no error was present upon reaching completion.
execution_url None
flyte_workflow None
id None :rtype: flytekit.models.core.identifier.WorkflowExecutionIdentifier
inputs None
is_done None Whether or not the execution is complete.
is_empty None
is_successful None Whether or not the execution is successful.
node_executions None Get a dictionary of node executions that are a part of this workflow execution.
outputs None :return: Returns the outputs LiteralsResolver to the execution :raises: FlyteAssertion error if execution is in progress or execution ended in error.
spec None :rtype: ExecutionSpec

Methods

Method Description
from_flyte_idl()
promote_from_model()
serialize_to_string()
short_string() :rtype: Text.
sync() Sync the state of the current execution and returns a new object with the updated state.
to_flyte_idl() :rtype: flyteidl.
wait() Wait for the execution to complete.

from_flyte_idl() 

def from_flyte_idl(
    pb,
)
Parameter Type Description
pb

promote_from_model() 

def promote_from_model(
    base_model: execution_models.Execution,
    remote: Optional['FlyteRemote'],
    type_hints: Optional[Dict[str, typing.Type]],
) -> 'FlyteWorkflowExecution'
Parameter Type Description
base_model execution_models.Execution
remote Optional['FlyteRemote']
type_hints Optional[Dict[str, typing.Type]]

serialize_to_string() 

def serialize_to_string()

short_string() 

def short_string()

:rtype: Text

sync() 

def sync(
    sync_nodes: bool,
) -> 'FlyteWorkflowExecution'

Sync the state of the current execution and returns a new object with the updated state.

Parameter Type Description
sync_nodes bool

to_flyte_idl() 

def to_flyte_idl()

:rtype: flyteidl.admin.execution_pb2.Execution

wait() 

def wait(
    timeout: Optional[Union[timedelta, int]],
    poll_interval: Optional[Union[timedelta, int]],
    sync_nodes: bool,
) -> 'FlyteWorkflowExecution'

Wait for the execution to complete. This is a blocking call.

Parameter Type Description
timeout Optional[Union[timedelta, int]] The maximum amount of time to wait for the execution to complete. It can be a timedelta or a duration in seconds as int.
poll_interval Optional[Union[timedelta, int]] The amount of time to wait between polling the state of the execution. It can be a timedelta or a duration in seconds as int.
sync_nodes bool Whether to sync the state of the nodes as well.

flytekit.remote.executions.RemoteExecutionBase 

class RemoteExecutionBase(
    args,
    kwargs,
)
Parameter Type Description
args *args
kwargs **kwargs

Properties

Property Type Description
error None
inputs None
is_done None
outputs None :return: Returns the outputs LiteralsResolver to the execution :raises: FlyteAssertion error if execution is in progress or execution ended in error.