0.1.dev2192+g7c539c3.d20250403

flytekit.models.array_job

Directory

Classes

Class Description
ArrayJob

flytekit.models.array_job.ArrayJob

class ArrayJob(
    parallelism,
    size,
    min_successes,
    min_success_ratio,
)

Initializes a new ArrayJob.

Parameter Type
parallelism
size
min_successes
min_success_ratio

Methods

Method Description
from_dict() .
from_flyte_idl() .
serialize_to_string()
short_string() :rtype: Text.
to_dict() :rtype: dict[T, Text].
to_flyte_idl()
verbose_string() :rtype: Text.

from_dict()

def from_dict(
    idl_dict,
) -> e: ArrayJob
Parameter Type
idl_dict

from_flyte_idl()

def from_flyte_idl(
    idl_object,
) -> n: FlyteCustomIdlEntity
Parameter Type
idl_object

serialize_to_string()

def serialize_to_string()

short_string()

def short_string()

:rtype: Text

to_dict()

def to_dict()

:rtype: dict[T, Text]

to_flyte_idl()

def to_flyte_idl()

verbose_string()

def verbose_string()

:rtype: Text

Properties

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

:rtype: int
parallelism
Defines the minimum number of instances to bring up concurrently at any given point.
:rtype: int
size
Defines the number of instances to launch at most. This number should match the size of the input if the job
requires processing of all input data. This has to be a positive number.
rtype: int