Schedule pods on a nodegroup on which no concurrent actions are executed (#7834)

* Schedule pods on a nodegroup on which no concurrent actions are executed

* patch test assertions

Author: TiberiuGC

integration/data/iamserviceaccount-checker.yaml

@@ -18,6 +18,8 @@ spec:
       serviceAccountName: s3-reader
       # use a shared volume
       volumes: [{name: aws-credentials, emptyDir: {}}]
+      nodeSelector:
+        used-for: test-pods
       initContainers:
         - name: assume-role
           image: atlassian/pipelines-awscli:1.16.185  

integration/data/podinfo.yaml

@@ -17,6 +17,8 @@ spec:
       annotations:
         prometheus.io/scrape: 'true'
     spec:
+      nodeSelector:
+        used-for: test-pods
       containers:
       - name: podinfod
         image: stefanprodan/podinfo:1.5.1@sha256:702633d438950f3675d0763a4ca6cfcf21a4d065cd7f470446c67607b1a26750

integration/data/test-dns.yaml

@@ -10,6 +10,8 @@ spec:
     metadata:
       labels: {test: dns}
     spec:
+      nodeSelector:
+        used-for: test-pods
       containers:
       - image: tutum/dnsutils@sha256:d2244ad47219529f1003bd1513f5c99e71655353a3a63624ea9cb19f8393d5fe
         name: dns-test-cluster

integration/data/test-http.yaml

@@ -10,6 +10,8 @@ spec:
     metadata:
       labels: {test: http}
     spec:
+      nodeSelector:
+        used-for: test-pods
       containers:
       - image: curlimages/curl@sha256:fa32ef426092b88ee0b569d6f81ab0203ee527692a94ec2e6ceb2fd0b6b2755c
         name: https-test-eksctl

integration/tests/crud/creategetdelete_test.go

@@ -66,6 +66,7 @@ func TestCRUD(t *testing.T) {
 }
 
 const (
+	deployNg        = "ng-deploy"
 	deleteNg        = "ng-delete"
 	taintsNg1       = "ng-taints-1"
 	taintsNg2       = "ng-taints-2"
@@ -131,6 +132,17 @@ var _ = SynchronizedBeforeSuite(func() []byte {
 		},
 	}
 	cfg.ManagedNodeGroups = []*api.ManagedNodeGroup{
+		{
+			NodeGroupBase: &api.NodeGroupBase{
+				Name: deployNg,
+				ScalingConfig: &api.ScalingConfig{
+					DesiredCapacity: aws.Int(5),
+				},
+				Labels: map[string]string{
+					"used-for": "test-pods",
+				},
+			},
+		},
 		{
 			NodeGroupBase: &api.NodeGroupBase{
 				Name: drainMng,
@@ -214,7 +226,7 @@ var _ = Describe("(Integration) Create, Get, Scale & Delete", func() {
 			Expect(session.ExitCode()).To(BeZero())
 			var stacks []*cfntypes.Stack
 			Expect(yaml.Unmarshal(session.Out.Contents(), &stacks)).To(Succeed())
-			Expect(stacks).To(HaveLen(6))
+			Expect(stacks).To(HaveLen(7))
 
 			var (
 				names, descriptions []string
@@ -227,6 +239,7 @@ var _ = Describe("(Integration) Create, Get, Scale & Delete", func() {
 
 			Expect(names).To(ContainElements(
 				ContainSubstring(params.ClusterName+"-cluster"),
+				ContainSubstring(ngPrefix+deployNg),
 				ContainSubstring(ngPrefix+deleteNg),
 				ContainSubstring(ngPrefix+scaleSingleNg),
 				ContainSubstring(ngPrefix+scaleMultipleNg),
@@ -1196,6 +1209,7 @@ var _ = Describe("(Integration) Create, Get, Scale & Delete", func() {
 				"-o", "json",
 				"--cluster", params.ClusterName,
 			)).To(RunSuccessfullyWithOutputString(BeNodeGroupsWithNamesWhich(
+				ContainElement(deployNg),
 				ContainElement(taintsNg1),
 				ContainElement(taintsNg2),
 				ContainElement(scaleSingleNg),