0.1.dev2192+g7c539c3.d20250403

flytekit.models.dynamic_job

Directory

Classes

Class Description
DynamicJobSpec

flytekit.models.dynamic_job.DynamicJobSpec

class DynamicJobSpec(
    tasks,
    nodes,
    min_successes,
    outputs,
    subworkflows,
)

Initializes a new FutureTaskDocument.

Parameter Type
tasks
nodes
min_successes
outputs
subworkflows

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(
    pb2_object,
) -> n: DynamicJobSpec
Parameter Type
pb2_object

serialize_to_string()

def serialize_to_string()

short_string()

def short_string()

:rtype: Text

to_flyte_idl()

def to_flyte_idl()

:rtype: flyteidl.core.dynamic_job.DynamicJobSpec

verbose_string()

def verbose_string()

:rtype: Text

Properties

Property Type Description
is_empty
min_successes
An absolute number of the minimum number of successful completions of subtasks. As
soon as this criteria is met, the future job will be marked as successful and outputs will be computed.

:rtype: int
nodes
A collection of dynamic nodes.
:rtype: list[_workflow.Node]
outputs
Describes how to bind the final output of the future task from the outputs of executed nodes.
The referenced ids in bindings should have the generated id for the subtask.

:rtype: list[flytekit.models.literals.Binding]
subworkflows
A collection of subworkflows to execute.
:rtype: list[flytekit.models.core.workflow.WorkflowTemplate]
tasks
A collection of tasks to execute.
:rtype: list[_task.TaskTemplate]