flytekit.models.array_job

Class	Description
`ArrayJob`

flytekit.models.array_job.ArrayJob

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

Initializes a new ArrayJob.

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. :rtype: int
`parallelism`	`None`	Defines the minimum number of instances to bring up concurrently at any given point. :rtype: int
`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. rtype: int

        
    
def from_dict(
    idl_dict,
)

Parameter	Type	Description
`idl_dict`

        
    
def from_flyte_idl(
    idl_object,
)

Parameter	Type	Description
`idl_object`

        
    
def serialize_to_string()

        
    
def short_string()

:rtype: Text

        
    
def to_dict()

:rtype: dict[T, Text]

        
    
def to_flyte_idl()

LLM-optimized This page Full docs index

On this page