fix test and add deep equal check

pkg/controllers/migration/crd/controller.go

@@ -31,6 +31,7 @@ import (
 	"sigs.k8s.io/controller-runtime/pkg/reconcile"
 
 	apiextensionsv1 "k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/v1"
+	"k8s.io/apimachinery/pkg/api/equality"
 	"k8s.io/apimachinery/pkg/api/errors"
 	"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
 	"k8s.io/apimachinery/pkg/runtime/schema"
@@ -99,11 +100,13 @@ func (c *Controller) Reconcile(ctx context.Context, crd *apiextensionsv1.CustomR
 	// if all custom resources have been updated, patch the CRD
 	stored := crd.DeepCopy()
 	crd.Status.StoredVersions = []string{"v1"}
-	if err := c.kubeClient.Status().Patch(ctx, crd, client.StrategicMergeFrom(stored, client.MergeFromWithOptimisticLock{})); client.IgnoreNotFound(err) != nil {
-		if errors.IsConflict(err) {
-			return reconcile.Result{Requeue: true}, nil
+	if !equality.Semantic.DeepEqual(stored, crd) {
+		if err := c.kubeClient.Status().Patch(ctx, crd, client.StrategicMergeFrom(stored, client.MergeFromWithOptimisticLock{})); client.IgnoreNotFound(err) != nil {
+			if errors.IsConflict(err) {
+				return reconcile.Result{Requeue: true}, nil
+			}
+			return reconcile.Result{}, fmt.Errorf("patching crd status version %s, %w", crd.Name, err)
 		}
-		return reconcile.Result{}, fmt.Errorf("patching crd status version %s, %w", crd.Name, err)
 	}
 	return reconcile.Result{}, nil
 }

pkg/controllers/migration/crd/suite_test.go

@@ -18,8 +18,8 @@ package crd_test
 
 import (
 	"context"
-	"strings"
 	"testing"
+	"time"
 
 	. "github.com/onsi/ginkgo/v2"
 	. "github.com/onsi/gomega"
@@ -44,11 +44,13 @@ import (
 	"sigs.k8s.io/karpenter/pkg/test/v1alpha1"
 )
 
-var ctx context.Context
-var env *test.Environment
-var resourceController *resource.Controller[*v1.NodeClaim]
-var crdController *crd.Controller
-var cloudProvider *fake.CloudProvider
+var (
+	ctx                context.Context
+	env                *test.Environment
+	resourceController *resource.Controller[*v1.NodeClaim]
+	crdController      *crd.Controller
+	cloudProvider      *fake.CloudProvider
+)
 
 func TestAPIs(t *testing.T) {
 	ctx = TestContextWithLogger(t)
@@ -70,10 +72,8 @@ var _ = AfterSuite(func() {
 var _ = Describe("Migration", func() {
 	var node *corev1.Node
 	var nodeClaim *v1.NodeClaim
-	var nodeClass *v1alpha1.TestNodeClass
 
 	BeforeEach(func() {
-		nodeClass = test.NodeClass()
 		nodeClaim, node = test.NodeClaimAndNode()
 		node.Labels[v1.NodePoolLabelKey] = test.NodePool().Name
 	})
@@ -84,15 +84,26 @@ var _ = Describe("Migration", func() {
 
 	Context("Stored Version", func() {
 		It("should update to v1 after custom resources have migrated", func() {
+			for _, item := range apis.CRDs {
+				crd := &apiextensionsv1.CustomResourceDefinition{}
+				Expect(env.Client.Get(ctx, client.ObjectKeyFromObject(item), crd)).To(Succeed())
+				stored := crd.DeepCopy()
+				crd.Status.StoredVersions = append(crd.Status.StoredVersions, "v1beta1")
+				Eventually(func(g Gomega) {
+					g.Expect(env.Client.Status().Patch(ctx, crd, client.StrategicMergeFrom(stored, client.MergeFromWithOptimisticLock{}))).To(Succeed())
+				}).WithTimeout(time.Second * 10).Should(Succeed())
+			}
 			ExpectApplied(ctx, env.Client, node, nodeClaim)
 			ExpectReconcileSucceeded(ctx, resourceController, client.ObjectKeyFromObject(nodeClaim))
 			nodeClaim = ExpectExists(ctx, env.Client, nodeClaim)
 			Expect(nodeClaim.Annotations).To(HaveKeyWithValue(v1.StoredVersionMigratedKey, "true"))
-			ExpectObjectReconciled(ctx, env.Client, crdController, v1alpha1.CRDs[0])
-			for _, crd := range env.CRDs {
-				if strings.Contains(crd.Name, strings.ToLower(nodeClass.Name)) {
-					Expect(crd.Status.StoredVersions).To(HaveExactElements("v1"))
-				}
+			for _, item := range apis.CRDs {
+				crd := &apiextensionsv1.CustomResourceDefinition{}
+				ExpectObjectReconciled(ctx, env.Client, crdController, item)
+				Eventually(func(g Gomega) {
+					g.Expect(env.Client.Get(ctx, client.ObjectKeyFromObject(item), crd)).To(Succeed())
+					g.Expect(crd.Status.StoredVersions).To(HaveExactElements("v1"))
+				}).WithTimeout(time.Second * 10).Should(Succeed())
 			}
 		})
 		It("shouldn't update the stored version to v1 if the storage version is v1beta1", func() {