Update Provider Test Snapshots

examples/examples_nodejs_test.go

@@ -285,6 +285,12 @@ func TestAccAwsProfile(t *testing.T) {
 		With(integration.ProgramTestOptions{
 			Dir: path.Join(getCwd(t), "aws-profile"),
 			ExtraRuntimeValidation: func(t *testing.T, info integration.RuntimeValidationStackInfo) {
+				// Manually set `AWS_PROFILE` to be the name of the profile used in the test, otherwise
+				// the test is expected to fail since we did not use the default profile. This is required
+				// to ensure multiple users with different profiles can use the Kubeconfig.
+				utils.EnsureKubeconfigFails(t, info.Outputs["kubeconfig"])
+				t.Setenv("AWS_PROFILE", os.Getenv("ALT_AWS_PROFILE"))
+
 				utils.RunEKSSmokeTest(t,
 					info.Deployment.Resources,
 					info.Outputs["kubeconfig"],

examples/examples_py_test.go

@@ -17,6 +17,7 @@
 package example
 
 import (
+	"os"
 	"path/filepath"
 	"testing"
 
@@ -32,6 +33,12 @@ func TestAccAwsProfilePy(t *testing.T) {
 			NoParallel: true,
 			Dir:        filepath.Join(getCwd(t), "aws-profile-py"),
 			ExtraRuntimeValidation: func(t *testing.T, info integration.RuntimeValidationStackInfo) {
+				// Manually set `AWS_PROFILE` to be the name of the profile used in the test, otherwise
+				// the test is expected to fail since we did not use the default profile. This is required
+				// to ensure multiple users with different profiles can use the Kubeconfig.
+				utils.EnsureKubeconfigFails(t, info.Outputs["kubeconfig"])
+				t.Setenv("AWS_PROFILE", os.Getenv("ALT_AWS_PROFILE"))
+
 				utils.RunEKSSmokeTest(t,
 					info.Deployment.Resources,
 					info.Outputs["kubeconfig"],

examples/utils/utils.go

@@ -652,3 +652,20 @@ func clientSetFromKubeconfig(kubeconfig any) (*kubernetes.Clientset, error) {
 	}
 	return clientSet, nil
 }
+
+// EnsureKubeconfigFails ensures that the provided kubeconfig fails to authenticate.
+func EnsureKubeconfigFails(t *testing.T, kubeconfig any) {
+	kc, err := json.Marshal(kubeconfig)
+	if err != nil {
+		t.Errorf("unable to marshal provided kubeconfig: %s", err)
+	}
+	kubeAccess, err := KubeconfigToKubeAccess(kc)
+	if err != nil {
+		t.Errorf("unable to create KubeAccess from kubeconfig: %s", err)
+	}
+
+	_, err = kubeAccess.Clientset.Discovery().ServerVersion()
+	if err == nil {
+		t.Errorf("expected kubeconfig to fail, but it succeeded to return the server version")
+	}
+}

nodejs/eks/cluster.ts

@@ -213,12 +213,6 @@ export function generateKubeconfig(
     if (opts?.roleArn) {
         args = [...args, "--role", opts.roleArn];
     }
-    if (opts?.profileName) {
-        env.push({
-            name: "AWS_PROFILE",
-            value: opts.profileName,
-        });
-    }
 
     return pulumi.all([args, env]).apply(([tokenArgs, envvars]) => {
         return {