From 876999ca9c64025315b52d2d5b04195c530fa3df Mon Sep 17 00:00:00 2001 From: Dan Rammer Date: Wed, 24 Apr 2024 15:29:14 -0500 Subject: [PATCH] enabling parallelism controls on arraynode (#5284) Signed-off-by: Daniel Rammer --- flytepropeller/pkg/controller/nodes/executor.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flytepropeller/pkg/controller/nodes/executor.go b/flytepropeller/pkg/controller/nodes/executor.go index 46da9134eb..1c42357623 100644 --- 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 {