TEST

test/e2e/suites/managed/eks_test.go

@@ -22,6 +22,7 @@ package managed
 import (
 	"context"
 	"fmt"
+	"time"
 
 	"github.com/onsi/ginkgo/v2"
 	. "github.com/onsi/gomega"
@@ -76,15 +77,20 @@ var _ = ginkgo.Describe("[managed] [general] EKS cluster tests", func() {
 		})
 
 		ginkgo.By("should set environment variables on the aws-node daemonset")
-		CheckAwsNodeEnvVarsSet(ctx, func() UpdateAwsNodeVersionSpecInput {
+		input := func() UpdateAwsNodeVersionSpecInput {
 			return UpdateAwsNodeVersionSpecInput{
 				E2EConfig:             e2eCtx.E2EConfig,
 				BootstrapClusterProxy: e2eCtx.Environment.BootstrapClusterProxy,
 				AWSSession:            e2eCtx.BootstrapUserAWSSession,
 				Namespace:             namespace,
 				ClusterName:           clusterName,
 			}
-		})
+		}
+		Eventually(func() error {
+			defer ginkgo.GinkgoRecover()
+			CheckAwsNodeEnvVarsSet(ctx, input)
+			return nil
+		}, time.Second*10, time.Minute*5).Should(Succeed(), "Failed to verify AWS Node environment variables after 5 minutes of retries")
 
 		ginkgo.By("should have the VPC CNI installed")
 		CheckAddonExistsSpec(ctx, func() CheckAddonExistsSpecInput {

test/e2e/suites/managed/managed_suite_test.go

@@ -49,7 +49,7 @@ func init() {
 	shared.CreateDefaultFlags(e2eCtx)
 	flag.BoolVar(&skipGeneralTests, "skip-eks-general-tests", false, "if true, the general EKS tests will be skipped")
 	flag.BoolVar(&skipUpgradeTests, "skip-eks-upgrade-tests", false, "if true, the EKS upgrade tests will be skipped")
-	flag.BoolVar(&skipLegacyTests, "skip-eks-legacy-tests", false, "if true, the EKS legacy tests will be skipped")
+	flag.BoolVar(&skipLegacyTests, "skip-eks-legacy-tests", true, "if true, the EKS legacy tests will be skipped")
 }
 
 func TestE2E(t *testing.T) {