ArrayNode

This class represents a node that executes a target Flyte entity, such as a launch plan or task, over a collection of inputs in an array-like fashion. It provides mechanisms to control execution through concurrency limits and success thresholds, supporting both minimum success counts and ratios. The class automatically transforms the target's interface to handle list-based inputs and outputs while managing data and execution modes based on the target entity type.

Attributes

Attribute	Type	Description
target	Union[LaunchPlan, ReferenceTask, FlyteLaunchPlan]	The target Flyte entity to map over
id	str	Unique identifier for the node, derived from the target entity's name.
metadata	Optional[NodeMetadata]	The metadata for the underlying node
concurrency	Optional[int]	If specified, this limits the number of mapped tasks than can run in parallel to the given batch size.
min_successes	Optional[int]	The minimum number of successful executions. If set, this takes precedence over min_success_ratio
min_success_ratio	Optional[float]	The minimum ratio of successful executions.
bindings	List[Binding]	A list of input bindings that define how data is passed to the mapped task instances.
python_interface	Interface	The transformed Python interface representing the list-based inputs and outputs of the array node.
interface	TypedInterface	The transformed backend-compatible typed interface for remote entities.
data_mode	ArrayNode.DataMode	Determines how input data is partitioned, such as using a single input file or individual files per map instance.
execution_mode	ArrayNode.ExecutionMode	Defines the state management strategy for the array node, such as full or minimal state tracking.

---

Constructor

Signature

def ArrayNode(
        self,
        target: Union[LaunchPlan, ReferenceTask, "FlyteLaunchPlan"],
        bindings: Optional[List[_literal_models.Binding]] = None,
        concurrency: Optional[int] = None,
        min_successes: Optional[int] = None,
        min_success_ratio: Optional[float] = None,
        metadata: Optional[_workflow_model.NodeMetadata] = None,
    ): ...

Parameters

Name	Type	Description
target	Union[LaunchPlan, ReferenceTask, FlyteLaunchPlan]	The target Flyte entity to map over.
bindings	Optional[List[_literal_models.Binding]] = None	A list of input bindings for the node.
concurrency	Optional[int] = None	Limits the number of mapped tasks that can run in parallel. Set to 0 for unbounded concurrency.
min_successes	Optional[int] = None	The minimum number of successful executions required.
min_success_ratio	Optional[float] = None	The minimum ratio of successful executions required (0.0 to 1.0).
metadata	Optional[_workflow_model.NodeMetadata] = None	Metadata for the underlying node.

---

Methods

---

construct_node_metadata()

def construct_node_metadata(self) -> _workflow_model.NodeMetadata: ...

Constructs and returns the metadata for the node, defaulting to the target entity's name if no specific metadata is provided.

Returns

Type	Description
_workflow_model.NodeMetadata	The metadata object containing configuration for the workflow node.

---

name()

@property
def name(self) -> str: ...

Retrieves the name of the target Flyte entity associated with this node.

Returns

Type	Description
str	The identifier string of the target entity.

---

python_interface()

@property
def python_interface(self) -> flyte_interface.Interface: ...

Provides the Python-native interface definition for the array node, which typically involves list-transformed inputs and outputs.

Returns

Type	Description
flyte_interface.Interface	The interface object representing the Python types for this node.

---

interface()

@property
def interface(self) -> _interface_models.TypedInterface: ...

Retrieves the serialized typed interface for the node; raises an AttributeError if a remote interface is not available.

Returns

Type	Description
_interface_models.TypedInterface	The Flyte IDL-compatible typed interface.

---

bindings()

@property
def bindings(self) -> List[_literal_models.Binding]: ...

Returns the list of input bindings that map workflow data to the node's parameters.

Returns

Type	Description
List[_literal_models.Binding]	A list of literal bindings used for serialization.

---

upstream_nodes()

@property
def upstream_nodes(self) -> List[Node]: ...

Returns the list of nodes that must execute before this node; currently returns an empty list for ArrayNodes.

Returns

Type	Description
List[Node]	An empty list of upstream node dependencies.

---

flyte_entity()

@property
def flyte_entity(self) -> Any: ...

Returns the underlying Flyte entity (e.g., LaunchPlan or Task) that this node is mapping over.

Returns

Type	Description
Any	The target Flyte entity object.

---

data_mode()

@property
def data_mode(self) -> _core_workflow.ArrayNode.DataMode: ...

Indicates how data is handled for the array node, such as whether it uses single or individual input files.

Returns

Type	Description
_core_workflow.ArrayNode.DataMode	The data mode enum value.

---

local_execute()

def local_execute(self, ctx: FlyteContext, **kwargs) -> Union[Tuple[Promise], Promise, VoidPromise]: ...

Executes the array node locally by iterating over input lists and invoking the target entity for each element. It validates success ratios and handles local state transitions.

Parameters

Name	Type	Description
ctx	FlyteContext	The execution context providing access to local configuration and state.
kwargs	Any	The keyword arguments representing the input data for the mapped execution.

Returns

Type	Description
Union[Tuple[Promise], Promise, VoidPromise]	A promise containing a collection of results, or a void promise if no outputs are expected.

---

local_execution_mode()

def local_execution_mode(self): ...

Returns the execution mode for local runs, identifying this as a local task execution.

Returns

Type	Description
ExecutionState.Mode	The local task execution mode constant.

---

min_success_ratio()

@property
def min_success_ratio(self) -> Optional[float]: ...

Returns the minimum ratio of successful sub-task executions required for the node to be considered successful.

Returns

Type	Description
Optional[float]	A float between 0 and 1, or None if min_successes is used instead.

---

min_successes()

@property
def min_successes(self) -> Optional[int]: ...

Returns the absolute minimum number of successful sub-task executions required.

Returns

Type	Description
Optional[int]	The integer count of required successes.

---

concurrency()

@property
def concurrency(self) -> Optional[int]: ...

Returns the maximum number of sub-tasks allowed to run in parallel.

Returns

Type	Description
Optional[int]	The concurrency limit, where 0 indicates unbounded parallelism.

---

execution_mode()

@property
def execution_mode(self) -> _core_workflow.ArrayNode.ExecutionMode: ...

Returns the execution mode (e.g., FULL_STATE or MINIMAL_STATE) based on the type of target entity.

Returns

Type	Description
_core_workflow.ArrayNode.ExecutionMode	The execution mode enum value.

---

is_original_sub_node_interface()

@property
def is_original_sub_node_interface(self) -> bool: ...

Indicates if the node uses the original sub-node interface; always returns True.

Returns

Type	Description
bool	Boolean flag for interface status.

---

bound_inputs()

@property
def bound_inputs(self) -> Set[str]: ...

Returns the set of inputs that are bound to specific values; currently returns an empty set.

Returns

Type	Description
Set[str]	A set of input variable names.

---