Allow custom downstream k8s version in the workflows

Signed-off-by: Parthvi <parthvi.vala@gmail.com>

.github/workflows/aks.yaml

@@ -45,6 +45,9 @@ on:
         description: Runner template to use
         default: hosted-prov-e2e-ci-runner-spot-n2-highmem-16-gl-template-v1
         type: string
+      provider_k8s_version:
+        description: Provider specific K8s version to test
+        default: 1.26.6
 
 jobs:
   aks-e2e:
@@ -61,3 +64,4 @@ jobs:
       run_support_matrix_importing_tests: ${{ inputs.run_support_matrix_importing_tests == true || (github.event_name == 'schedule' && false) }}
       destroy_runner: ${{ inputs.destroy_runner ==true || (github.event_name == 'schedule' && true) }}
       runner_template: ${{ inputs.runner_template || 'hosted-prov-e2e-ci-runner-spot-n2-highmem-16-gl-template-v1' }}
+      provider_k8s_version: ${{ inputs.provider_k8s_version || '1.26.6' }}

.github/workflows/eks.yaml

@@ -45,7 +45,9 @@ on:
         description: Runner template to use
         default: hosted-prov-e2e-ci-runner-spot-n2-highmem-16-gl-template-v1
         type: string
-
+      provider_k8s_version:
+        description: Provider specific K8s version to test
+        default: 1.26
 jobs:
   eks-e2e:
     uses: ./.github/workflows/main.yaml
@@ -61,3 +63,4 @@ jobs:
       run_support_matrix_importing_tests: ${{ inputs.run_support_matrix_importing_tests == true || (github.event_name == 'schedule' && false) }}
       destroy_runner: ${{ inputs.destroy_runner ==true || (github.event_name == 'schedule' && true) }}
       runner_template: ${{ inputs.runner_template || 'hosted-prov-e2e-ci-runner-spot-n2-highmem-16-gl-template-v1' }}
+      provider_k8s_version: ${{ inputs.provider_k8s_version || '1.26' }}

.github/workflows/gke.yaml

@@ -45,7 +45,9 @@ on:
         description: Runner template to use
         default: hosted-prov-e2e-ci-runner-spot-n2-highmem-16-gl-template-v1
         type: string
-
+      provider_k8s_version:
+        description: Provider specific K8s version to test
+        default: 1.27.4-gke.900
 jobs:
   gke-e2e:
     uses: ./.github/workflows/main.yaml
@@ -61,3 +63,4 @@ jobs:
       run_support_matrix_importing_tests: ${{ inputs.run_support_matrix_importing_tests == true || (github.event_name == 'schedule' && false) }}
       destroy_runner: ${{ inputs.destroy_runner ==true || (github.event_name == 'schedule' && true) }}
       runner_template: ${{ inputs.runner_template || 'hosted-prov-e2e-ci-runner-spot-n2-highmem-16-gl-template-v1' }}
+      provider_k8s_version: ${{ inputs.provider_k8s_version || '1.27.4-gke.900' }}

.github/workflows/main.yaml

@@ -39,6 +39,9 @@ on:
         description: Runner template to use
         required: true
         type: string
+      provider_k8s_version:
+        description: Provider specific K8s version to test
+        type: string
 
 env:
   AWS_ACCESS_KEY_ID: ${{ secrets.AWS_ACCESS_KEY_ID }}
@@ -54,6 +57,7 @@ env:
   RANCHER_PASSWORD: ${{ secrets.RANCHER_PASSWORD }}
   RANCHER_LOG_COLLECTOR: ${{ github.workspace }}/.github/scripts/collect-rancher-logs.sh
   GCP_RUNNER_ZONE: asia-south2-c
+  KUBERNETES_VERSION: ${{ inputs.provider_k8s_version }}
 jobs:
   create-runner:
     runs-on: ubuntu-latest

README.md

@@ -14,6 +14,7 @@ Following are the common environment variables that need to be exported for runn
 2. RANCHER_PASSWORD - Admin Password for login. We currently only test with 'admin' user.
 3. CATTLE_TEST_CONFIG: Config file containing cluster and cloud credential information, for e.g. cattle-config-provisioning.yaml and cattle-config-import.yaml in the root directory.
 4. PROVIDER: Type of the hosted provider you want to test. Acceptable values - gke, eks, aks
+5. KUBERNETES_VERSION(Optional): Provider specific Kubernetes version to test. If the env var is not provided, the value is obtained from the config, if even that is not available, it uses a provider specific default value.
 
 To run GKE:
 1. GCP_CREDENTIALS - a Service Account with a JSON private key and provide the JSON here. These IAM roles are required:

hosted/aks/p0/p0_suite_test.go

@@ -10,14 +10,14 @@ import (
 )
 
 const (
-	k8sVersion = "1.26.6"
 	increaseBy = 1
 )
 
 var (
 	ctx         helpers.Context
 	clusterName string
 	location    = helpers.GetAKSLocation()
+	k8sVersion  = helpers.GetK8sVersion("aks")
 )
 
 func TestP0(t *testing.T) {

hosted/eks/p0/p0_suite_test.go

@@ -10,14 +10,14 @@ import (
 )
 
 const (
-	k8sVersion = "1.26"
 	increaseBy = 1
 )
 
 var (
 	ctx         helpers.Context
 	clusterName string
 	region      = helpers.GetEKSRegion()
+	k8sVersion  = helpers.GetK8sVersion("eks")
 )
 
 func TestP0(t *testing.T) {

hosted/gke/p0/p0_suite_test.go

@@ -10,7 +10,6 @@ import (
 )
 
 const (
-	k8sVersion = "1.27.4-gke.900"
 	increaseBy = 1
 )
 
@@ -19,6 +18,7 @@ var (
 	clusterName string
 	zone        = helpers.GetGKEZone()
 	project     = helpers.GetGKEProjectID()
+	k8sVersion  = helpers.GetK8sVersion("gke")
 )
 
 func TestP0(t *testing.T) {

hosted/helpers/helper_common.go

@@ -3,6 +3,9 @@ package helpers
 import (
 	"fmt"
 	"github.com/onsi/ginkgo/v2"
+	"github.com/rancher/rancher/tests/framework/extensions/clusters/aks"
+	"github.com/rancher/rancher/tests/framework/extensions/clusters/eks"
+	"github.com/rancher/rancher/tests/framework/extensions/clusters/gke"
 	"os"
 	"os/user"
 	"strings"
@@ -202,3 +205,38 @@ func GetCommonMetadataLabels() map[string]string {
 		"testfilenumber": filename,
 	}
 }
+
+func GetK8sVersion(provider string) string {
+	k8sVersion := os.Getenv("KUBERNETES_VERSION")
+	if k8sVersion != "" {
+		return k8sVersion
+	}
+	switch provider {
+	case "gke":
+		gkeConfig := new(management.GKEClusterConfigSpec)
+		config.LoadConfig(gke.GKEClusterConfigConfigurationFileKey, gkeConfig)
+		if gkeConfig.KubernetesVersion != nil {
+			k8sVersion = *gkeConfig.KubernetesVersion
+		} else {
+			k8sVersion = "1.27.4-gke.900"
+		}
+	case "eks":
+		eksConfig := new(management.EKSClusterConfigSpec)
+		config.LoadConfig(eks.EKSClusterConfigConfigurationFileKey, eksConfig)
+		if eksConfig.KubernetesVersion != nil {
+			k8sVersion = *eksConfig.KubernetesVersion
+		} else {
+			k8sVersion = "1.26"
+
+		}
+	case "aks":
+		aksConfig := new(management.AKSClusterConfigSpec)
+		config.LoadConfig(aks.AKSClusterConfigConfigurationFileKey, aksConfig)
+		if aksConfig.KubernetesVersion != nil {
+			k8sVersion = *aksConfig.KubernetesVersion
+		} else {
+			k8sVersion = "1.26.6"
+		}
+	}
+	return k8sVersion
+}