ci/e2e: install the 3rd first nodes all in parallel

This will reduce CI execution time.

Signed-off-by: Loic Devulder <ldevulder@suse.com>

.github/workflows/master-e2e.yaml

@@ -301,18 +301,13 @@ jobs:
       - name: Configure Rancher & Libvirt
         if: inputs.test_type == 'cli'
         run: cd tests && make e2e-configure-rancher
-      - name: Bootstrap node 1 with current build (use Emulated TPM and iPXE)
-        if: inputs.test_type == 'cli'
-        env:
-          EMULATE_TPM: true
-          VM_INDEX: 1
-        run: cd tests && make e2e-bootstrap-node
-      - name: Bootstrap node 2 and 3 with current build (use Emulated TPM and ISO)
+      - name: Bootstrap node 1, 2 and 3 with current build (use Emulated TPM and ISO) in pool "master"
         if: inputs.test_type == 'cli'
         env:
           EMULATE_TPM: true
           ISO_BOOT: true
-          VM_INDEX: 2
+          POOL: master
+          VM_INDEX: 1
           VM_NUMBERS: 3
         run: |
           OPERATOR_VERSION=$(kubectl get pods \
@@ -325,9 +320,10 @@ jobs:
           [[ "${OPERATOR_VERSION}" == "1.0" ]] && unset EMULATE_TPM
 
           cd tests && make e2e-bootstrap-node
-      - name: Bootstrap additional nodes (total of ${{ inputs.node_number }}) with current build (use iPXE)
+      - name: Bootstrap additional nodes (total of ${{ inputs.node_number }}) with current build (use iPXE) in pool "worker"
         if: inputs.test_type == 'cli' && inputs.node_number > 3
         env:
+          POOL: worker
           VM_INDEX: 4
           VM_NUMBERS: ${{ inputs.node_number }}
         run: cd tests && make e2e-bootstrap-node
@@ -437,4 +433,3 @@ jobs:
           gcloud --quiet compute instances delete ${{ needs.create-runner.outputs.runner }} \
             --delete-disks all \
             --zone ${{ inputs.zone }}
-

tests/assets/cluster.yaml

@@ -13,7 +13,7 @@ spec:
         kind: MachineInventorySelectorTemplate
         name: selector-master-%CLUSTER_NAME%
       name: pool-master-%CLUSTER_NAME%
-      quantity: 1
+      quantity: 0
       workerRole: true
     - controlPlaneRole: false
       etcdRole: false

tests/e2e/bootstrap_test.go

@@ -82,26 +82,13 @@ func getNodeInfo(hostName string, index int) (*tools.Client, string) {
 
 var _ = Describe("E2E - Bootstrapping node", Label("bootstrap"), func() {
 	var (
-		machineRegName string
-		poolType       string
-		wg             sync.WaitGroup
+		wg sync.WaitGroup
 	)
 
-	BeforeEach(func() {
-		// Set pool type
-		if vmIndex < 4 {
-			// First third nodes are in Master pool
-			poolType = "master"
-		} else {
-			// The others are in Worker pool
-			poolType = "worker"
-		}
-
+	It("Provision the node", func() {
 		// Set MachineRegistration name based on hostname
-		machineRegName = "machine-registration-" + poolType + "-" + clusterName
-	})
+		machineRegName := "machine-registration-" + poolType + "-" + clusterName
 
-	It("Provision the node", func() {
 		By("Setting emulated TPM to "+strconv.FormatBool(emulateTPM), func() {
 			// Set temporary file
 			emulatedTmp, err := misc.CreateTemp("emulatedTPM")
@@ -220,22 +207,24 @@ var _ = Describe("E2E - Bootstrapping node", Label("bootstrap"), func() {
 			By("Ensuring that the cluster is in healthy state", func() {
 				checkClusterState()
 			})
+		}
 
-			By("Increasing 'quantity' node of predefined cluster", func() {
-				comparator := ">"
-				if poolType == "worker" {
-					// In case of worker the first value could be equal to 1
-					comparator = ">="
-				}
+		By("Increment number of nodes in pool "+poolType, func() {
+			// Increase 'quantity' field
+			value, err := misc.IncreaseQuantity(clusterNS,
+				clusterName,
+				"pool-"+poolType+"-"+clusterName, addedNode)
+			Expect(err).To(Not(HaveOccurred()))
+			Expect(value).To(BeNumerically(">=", 1))
 
-				// Increase 'quantity' field
-				value, err := misc.IncreaseQuantity(clusterNS,
-					clusterName,
-					"pool-"+poolType+"-"+clusterName, addedNode)
-				Expect(err).To(Not(HaveOccurred()))
-				Expect(value).To(BeNumerically(comparator, 1))
-			})
-		}
+			// Check that the selector has been correctly created
+			Eventually(func() string {
+				out, _ := kubectl.Run("get", "MachineInventorySelector",
+					"--namespace", clusterNS,
+					"-o", "jsonpath={.items[*].metadata.name}")
+				return out
+			}, misc.SetTimeout(3*time.Minute), 5*time.Second).Should(ContainSubstring("selector-" + poolType + "-" + clusterName))
+		})
 
 		By("Waiting for known cluster state before adding the node(s)", func() {
 			msg := `(configuring .* node\(s\)|waiting for viable init node)`

tests/e2e/configure_test.go

@@ -101,17 +101,6 @@ var _ = Describe("E2E - Configure test", Label("configure"), func() {
 						"-o", "jsonpath={.items[*].metadata.name}")
 					return out
 				}, misc.SetTimeout(3*time.Minute), 5*time.Second).Should(ContainSubstring("selector-" + pool + "-" + clusterName))
-
-				// Check that the selector for master is correctly created
-				// NOTE: the worker one is not created yet because 'quantity' is set to 0 for this one
-				if pool == "master" {
-					Eventually(func() string {
-						out, _ := kubectl.Run("get", "MachineInventorySelector",
-							"--namespace", clusterNS,
-							"-o", "jsonpath={.items[*].metadata.name}")
-						return out
-					}, misc.SetTimeout(3*time.Minute), 5*time.Second).Should(ContainSubstring("selector-" + pool + "-" + clusterName))
-				}
 			}
 		})
 

tests/e2e/suite_test.go

@@ -61,6 +61,7 @@ var (
 	k8sVersion          string
 	numberOfVMs         int
 	osImage             string
+	poolType            string
 	proxy               string
 	rancherChannel      string
 	rancherLogCollector string
@@ -98,6 +99,7 @@ var _ = BeforeSuite(func() {
 	k8sVersion = os.Getenv("K8S_VERSION_TO_PROVISION")
 	number := os.Getenv("VM_NUMBERS")
 	osImage = os.Getenv("CONTAINER_IMAGE")
+	poolType = os.Getenv("POOL")
 	proxy = os.Getenv("PROXY")
 	rancherChannel = os.Getenv("RANCHER_CHANNEL")
 	rancherLogCollector = os.Getenv("RANCHER_LOG_COLLECTOR")