Disable increaseSize when the node group is under initialilzation.

Author: nilo19

cluster-autoscaler/cloudprovider/azure/azure_agent_pool.go

@@ -75,6 +75,7 @@ func NewAgentPool(spec *dynamic.NodeGroupSpec, az *AzureManager) (*AgentPool, er
 		minSize: spec.MinSize,
 		maxSize: spec.MaxSize,
 		manager: az,
+		curSize: -1,
 	}
 
 	if err := as.initialize(); err != nil {
@@ -302,6 +303,10 @@ func (as *AgentPool) IncreaseSize(delta int) error {
 	as.mutex.Lock()
 	defer as.mutex.Unlock()
 
+	if as.curSize == -1 {
+		return fmt.Errorf("the availability set %s is under initialization, skipping IncreaseSize", as.Name)
+	}
+
 	if delta <= 0 {
 		return fmt.Errorf("size increase must be positive")
 	}

cluster-autoscaler/cloudprovider/azure/azure_scale_set.go

@@ -336,6 +336,10 @@ func (scaleSet *ScaleSet) IncreaseSize(delta int) error {
 		return err
 	}
 
+	if size == -1 {
+		return fmt.Errorf("the scale set %s is under initialization, skipping IncreaseSize", scaleSet.Name)
+	}
+
 	if int(size)+delta > scaleSet.MaxSize() {
 		return fmt.Errorf("size increase too large - desired:%d max:%d", int(size)+delta, scaleSet.MaxSize())
 	}

cluster-autoscaler/cloudprovider/azure/azure_scale_set_test.go

@@ -20,6 +20,7 @@ import (
 	"fmt"
 	"net/http"
 	"testing"
+	"time"
 
 	apiv1 "k8s.io/api/core/v1"
 	"k8s.io/autoscaler/cluster-autoscaler/cloudprovider"
@@ -130,6 +131,13 @@ func TestIncreaseSize(t *testing.T) {
 	mockVMSSVMClient.EXPECT().List(gomock.Any(), provider.azureManager.config.ResourceGroup, "test-asg", gomock.Any()).Return(expectedVMSSVMs, nil).AnyTimes()
 	provider.azureManager.azClient.virtualMachineScaleSetVMsClient = mockVMSSVMClient
 
+	ss := newTestScaleSet(provider.azureManager, "test-asg")
+	ss.lastSizeRefresh = time.Now()
+	ss.curSize = -1
+	err := ss.IncreaseSize(100)
+	expectedErr := fmt.Errorf("the scale set test-asg is under initialization, skipping IncreaseSize")
+	assert.Equal(t, expectedErr, err)
+
 	registered := provider.azureManager.RegisterAsg(
 		newTestScaleSet(provider.azureManager, "test-asg"))
 	assert.True(t, registered)