enabling parallelism controls on arraynode (#5284)

Signed-off-by: Daniel Rammer <[email protected]>
flyteorg · Apr 24, 2024 · 876999c · 876999c
1 parent 5c77765
commit 876999c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flytepropeller/pkg/controller/nodes/executor.go b/flytepropeller/pkg/controller/nodes/executor.go
@@ -153,7 +153,7 @@ func IsMaxParallelismAchieved(ctx context.Context, currentNode v1alpha1.Executab
 		return false
 	}
 
-	if currentNode.GetKind() == v1alpha1.NodeKindTask ||
+	if currentNode.GetKind() == v1alpha1.NodeKindTask || currentNode.GetKind() == v1alpha1.NodeKindArray ||
 		(currentNode.GetKind() == v1alpha1.NodeKindWorkflow && currentNode.GetWorkflowNode() != nil && currentNode.GetWorkflowNode().GetLaunchPlanRefID() != nil) {
 		// If we are queued, let us see if we can proceed within the node parallelism bounds
 		if execContext.CurrentParallelism() >= maxParallelism {