Fix resource manager and debug

go/tasks/plugins/array/k8s/monitor.go

@@ -60,6 +60,7 @@ func LaunchAndCheckSubTasksState(ctx context.Context, tCtx core.TaskExecutionCon
 
 	for childIdx, existingPhaseIdx := range currentState.GetArrayStatus().Detailed.GetItems() {
 		existingPhase := core.Phases[existingPhaseIdx]
+		logger.Debugf(ctx, "Current phase and index %v - %v", childIdx, existingPhase)
 		indexStr := strconv.Itoa(childIdx)
 		podName := formatSubTaskName(ctx, tCtx.TaskExecutionMetadata().GetTaskExecutionID().GetGeneratedName(), indexStr)
 		if existingPhase.IsTerminal() {
@@ -68,6 +69,7 @@ func LaunchAndCheckSubTasksState(ctx context.Context, tCtx core.TaskExecutionCon
 
 			// Since we know we have already "processed" this terminal phase we can safely deallocate resource
 			err = deallocateResource(ctx, tCtx, config, childIdx)
+			logger.Debugf(ctx, "K8s array - deallocate resource")
 			if err != nil {
 				logger.Errorf(ctx, "Error releasing allocation token [%s] in LaunchAndCheckSubTasks [%s]", podName, err)
 				return currentState, logLinks, errors2.Wrapf(ErrCheckPodStatus, err, "Error releasing allocation token.")

go/tasks/plugins/array/k8s/task.go

@@ -194,7 +194,10 @@ func allocateResource(ctx context.Context, tCtx core.TaskExecutionContext, confi
 	}
 
 	resourceNamespace := core.ResourceNamespace(config.ResourceConfig.PrimaryLabel)
-	resourceConstraintSpec := createResourceConstraintsSpec(ctx, tCtx)
+	resourceConstraintSpec := core.ResourceConstraintsSpec{
+		ProjectScopeResourceConstraint:   nil,
+		NamespaceScopeResourceConstraint: nil,
+	}
 
 	allocationStatus, err := tCtx.ResourceManager().AllocateResource(ctx, resourceNamespace, podName, resourceConstraintSpec)
 	if err != nil {
@@ -223,16 +226,3 @@ func deallocateResource(ctx context.Context, tCtx core.TaskExecutionContext, con
 
 	return nil
 }
-
-func createResourceConstraintsSpec(ctx context.Context, _ core.TaskExecutionContext) core.ResourceConstraintsSpec {
-	constraintsSpec := core.ResourceConstraintsSpec{
-		ProjectScopeResourceConstraint:   nil,
-		NamespaceScopeResourceConstraint: nil,
-	}
-
-	constraintsSpec.ProjectScopeResourceConstraint = &core.ResourceConstraint{Value: int64(1)}
-	constraintsSpec.NamespaceScopeResourceConstraint = &core.ResourceConstraint{Value: int64(1)}
-	logger.Infof(ctx, "Created a resource constraints spec: [%v]", constraintsSpec)
-
-	return constraintsSpec
-}