The page you navigated to () does not exist, so we brought you to the closest page to it.
You have switched from the to the variant of this site. There is no equivalent of . We have taken you to the closest page in the variant.
1.16.16
flytekit.models.array_job
Directory
Classes
| Class | Description |
|---|---|
ArrayJob |
flytekit.models.array_job.ArrayJob
Parameters
class ArrayJob(
parallelism,
size,
min_successes,
min_success_ratio,
)Initializes a new ArrayJob.
| Parameter | Type | Description |
|---|---|---|
parallelism |
||
size |
||
min_successes |
||
min_success_ratio |
Properties
| Property | Type | Description |
|---|---|---|
is_empty |
None |
|
min_success_ratio |
None |
|
min_successes |
None |
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. |
parallelism |
None |
Defines the minimum number of instances to bring up concurrently at any given point. |
size |
None |
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. |
Methods
| Method | Description |
|---|---|
from_dict() |
|
from_flyte_idl() |
|
serialize_to_string() |
|
short_string() |
|
to_dict() |
|
to_flyte_idl() |
from_dict()
def from_dict(
idl_dict,
)| Parameter | Type | Description |
|---|---|---|
idl_dict |
Returns: ArrayJob
from_flyte_idl()
def from_flyte_idl(
idl_object,
)| Parameter | Type | Description |
|---|---|---|
idl_object |
Returns: FlyteCustomIdlEntity
serialize_to_string()
def serialize_to_string()short_string()
def short_string()Returns: Text
to_dict()
def to_dict()Returns: dict[T, Text]
to_flyte_idl()
def to_flyte_idl()