diff --git a/internal/controller/suite_test.go b/internal/controller/suite_test.go index d2c7c6d..cac40f1 100644 --- a/internal/controller/suite_test.go +++ b/internal/controller/suite_test.go @@ -30,9 +30,13 @@ import ( . "github.com/onsi/ginkgo/v2" . "github.com/onsi/gomega" + corev1 "k8s.io/api/core/v1" + "k8s.io/apimachinery/pkg/api/meta" + "k8s.io/apimachinery/pkg/fields" "k8s.io/client-go/kubernetes/scheme" "k8s.io/client-go/rest" ctrl "sigs.k8s.io/controller-runtime" + "sigs.k8s.io/controller-runtime/pkg/cache" "sigs.k8s.io/controller-runtime/pkg/client" "sigs.k8s.io/controller-runtime/pkg/envtest" logf "sigs.k8s.io/controller-runtime/pkg/log" @@ -91,6 +95,21 @@ var _ = BeforeSuite(func() { k8sManager, err := ctrl.NewManager(cfg, ctrl.Options{ Scheme: scheme.Scheme, + Cache: cache.Options{ + ByObject: map[client.Object]cache.ByObject{ + &corev1.Pod{}: { + Field: fields.OneTermEqualSelector("status.phase", string(corev1.PodPending)), + Transform: func(obj any) (any, error) { + if accessor, err := meta.Accessor(obj); err == nil { + if accessor.GetManagedFields() != nil { + accessor.SetManagedFields(nil) + } + } + return obj, nil + }, + }, + }, + }, }) Expect(err).NotTo(HaveOccurred())