1.16.14

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 Description
tasks
nodes
min_successes
outputs
subworkflows

Properties

Property Type Description
is_empty None
min_successes None 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 None A collection of dynamic nodes. :rtype: list[_workflow.Node]
outputs None 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 None A collection of subworkflows to execute. :rtype: list[flytekit.models.core.workflow.WorkflowTemplate]
tasks None A collection of tasks to execute. :rtype: list[_task.TaskTemplate]

Methods

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

from_flyte_idl() 

def from_flyte_idl(
    pb2_object,
)
Parameter Type Description
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