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, :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 |