Conformance: update objects in MustApplyObjectsWithCleanup

conformance/utils/kubernetes/apply.go

@@ -220,14 +220,36 @@ func (a Applier) MustApplyObjectsWithCleanup(t *testing.T, c client.Client, time
 		ctx, cancel := context.WithTimeout(context.Background(), timeoutConfig.CreateTimeout)
 		defer cancel()
 
-		t.Logf("Creating %s %s", resource.GetName(), resource.GetObjectKind().GroupVersionKind().Kind)
-
-		err := c.Create(ctx, resource)
+		// Check if the resource exists
+		existingResource := resource.DeepCopyObject().(client.Object)
+		err := c.Get(ctx, types.NamespacedName{Name: resource.GetName(), Namespace: resource.GetNamespace()}, existingResource)
 		if err != nil {
-			if !apierrors.IsAlreadyExists(err) {
-				require.NoError(t, err, "error creating resource")
+			if !apierrors.IsNotFound(err) {
+				require.NoError(t, err, "error getting resource")
+			}
+
+			t.Logf("Creating %s %s", resource.GetName(), resource.GetObjectKind().GroupVersionKind().Kind)
+			err = c.Create(ctx, resource)
+			require.NoError(t, err, "error creating resource")
+
+			if cleanup {
+				t.Cleanup(func() {
+					ctx, cancel = context.WithTimeout(context.Background(), timeoutConfig.DeleteTimeout)
+					defer cancel()
+					t.Logf("Deleting %s %s", resource.GetName(), resource.GetObjectKind().GroupVersionKind().Kind)
+					err = c.Delete(ctx, resource)
+					require.NoErrorf(t, err, "error deleting resource")
+				})
 			}
+			continue
 		}
+		// Resource exists, update it
+		t.Logf("Updating %s %s", resource.GetName(), resource.GetObjectKind().GroupVersionKind().Kind)
+
+		resource.SetResourceVersion(existingResource.GetResourceVersion())
+
+		err = c.Update(ctx, resource)
+		require.NoErrorf(t, err, "error updating resource")
 
 		if cleanup {
 			t.Cleanup(func() {
@@ -238,6 +260,7 @@ func (a Applier) MustApplyObjectsWithCleanup(t *testing.T, c client.Client, time
 				require.NoErrorf(t, err, "error deleting resource")
 			})
 		}
+
 	}
 }