fix(test): add immediate storage class support and GinkgoRecover

- Add PrecheckImmediateStorageClass label for phase transition tests
- Get immediate storage class to ensure disk becomes Ready immediately
- Register defer early to ensure verification runs on test failure
- Add GinkgoRecover to handle panics in goroutine

Signed-off-by: Roman Sysoev <roman.sysoev@flant.com>

Author: Roman Sysoev

test/e2e/blockdevice/vd_phase_transitions.go

@@ -30,7 +30,7 @@ import (
 	"github.com/deckhouse/virtualization/test/e2e/internal/util"
 )
 
-var _ = Describe("VirtualDiskPhaseTransitions", label.Slow(), Label(precheck.NoPrecheck), func() {
+var _ = Describe("VirtualDiskPhaseTransitions", label.Slow(), Label(precheck.PrecheckImmediateStorageClass), func() {
 	var f *framework.Framework
 
 	BeforeEach(func() {
@@ -42,8 +42,13 @@ var _ = Describe("VirtualDiskPhaseTransitions", label.Slow(), Label(precheck.NoP
 	It("tracks phase transitions during export", func() {
 		var vd *v1alpha2.VirtualDisk
 
+		// Get immediate storage class for the test to ensure disk becomes Ready immediately
+		sc := framework.GetConfig().StorageClass.ImmediateStorageClass
+		Expect(sc).NotTo(BeNil(), "immediate storage class is required for this test")
+
 		By("Creating VirtualDisk from CVI", func() {
-			vd = object.NewVDFromCVI("vd-test", f.Namespace().Name, object.PrecreatedCVIAlpineBIOS)
+			vd = object.NewVDFromCVI("vd-test", f.Namespace().Name, object.PrecreatedCVIAlpineBIOS,
+				object.WithStorageClass(&sc.Name))
 
 			err := f.CreateWithDeferredDeletion(context.Background(), vd)
 			Expect(err).NotTo(HaveOccurred())
@@ -57,20 +62,19 @@ var _ = Describe("VirtualDiskPhaseTransitions", label.Slow(), Label(precheck.NoP
 			watcher := util.WatchPhases(context.Background(), vd)
 			Expect(watcher).NotTo(BeNil(), "failed to create event watcher for VirtualDisk")
 
+			// Register defer early to ensure verification runs even if test fails later
+			defer util.VerifyPhaseTransitions(watcher,
+				string(v1alpha2.DiskReady),
+				string(v1alpha2.DiskExporting),
+				string(v1alpha2.DiskReady))
+
 			By("Exporting VirtualDisk", func() {
 				DataExport(f, "vd", vd.Name, "exported-disk-phases.img")
 			})
 
 			By("Waiting for VirtualDisk to return to Ready after export", func() {
 				util.UntilObjectPhase(string(v1alpha2.DiskReady), framework.LongTimeout, vd)
 			})
-
-			DeferCleanup(func() {
-				util.VerifyPhaseTransitions(watcher,
-					string(v1alpha2.DiskReady),
-					string(v1alpha2.DiskExporting),
-					string(v1alpha2.DiskReady))
-			})
 		})
 	})
 })

test/e2e/internal/object/vd.go

@@ -64,3 +64,8 @@ func NewVDFromCVI(name, namespace, cviName string, opts ...vd.Option) *v1alpha2.
 	baseOpts = append(baseOpts, opts...)
 	return vd.New(baseOpts...)
 }
+
+// WithStorageClass is an option to set storage class for VirtualDisk.
+func WithStorageClass(storageClass *string) vd.Option {
+	return vd.WithStorageClass(storageClass)
+}

test/e2e/internal/util/event_watcher.go

@@ -136,6 +136,8 @@ func kindToResource(gvk schema.GroupVersionKind) (schema.GroupVersionResource, e
 }
 
 func (ew *EventPhaseWatcher) run(ctx context.Context) {
+	defer GinkgoRecover()
+
 	dynClient := framework.GetClients().DynamicClient()
 
 	watcher, err := dynClient.Resource(ew.gvr).