From fd6e31e17bcb2891fad06d98df3be671c77488eb Mon Sep 17 00:00:00 2001 From: Dan Rammer Date: Tue, 6 Sep 2022 17:23:15 -0500 Subject: [PATCH] updated system retries array max value (#284) Signed-off-by: Daniel Rammer Signed-off-by: Daniel Rammer --- flyteplugins/go/tasks/plugins/array/k8s/management.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flyteplugins/go/tasks/plugins/array/k8s/management.go b/flyteplugins/go/tasks/plugins/array/k8s/management.go index 8d504cb9e..a29967ac1 100644 --- a/flyteplugins/go/tasks/plugins/array/k8s/management.go +++ b/flyteplugins/go/tasks/plugins/array/k8s/management.go @@ -107,7 +107,7 @@ func LaunchAndCheckSubTasksState(ctx context.Context, tCtx core.TaskExecutionCon // interruptible subtasks. if len(currentState.SystemFailures.GetItems()) == 0 { count := uint(currentState.GetExecutionArraySize()) - maxValue := bitarray.Item(tCtx.TaskExecutionMetadata().GetInterruptibleFailureThreshold()) + maxValue := bitarray.Item(tCtx.TaskExecutionMetadata().GetMaxAttempts()) systemFailuresArray, err := bitarray.NewCompactArray(count, maxValue) if err != nil {