fix: when vmExport is in skipped phase, exit task

vm export cannot recover from skipped phase and thus it doesn't make
sense to wait.

Signed-off-by: Karel Simon <ksimon@redhat.com>

Author: ksimon1

modules/disk-uploader/pkg/vmexport/vmexport.go

@@ -63,6 +63,11 @@ func WaitUntilVirtualMachineExportReady(client kubecli.KubevirtClient, namespace
 		if vmExport.Status != nil {
 			log.Logger().Info("VirtualMachineExport object status", zap.String("status", string(vmExport.Status.Phase)))
 
+			if vmExport.Status.Phase == v1beta1.Skipped {
+				log.Logger().Error("VirtualMachineExport is in Skipped state, and can't be exported - exiting.")
+				return false, fmt.Errorf("VirtualMachineExport is in skipped phase")
+			}
+
 			if vmExport.Status.Phase == v1beta1.Ready {
 				log.Logger().Info("VirtualMachineExport is in Ready state, and export source is not longer used")
 				return true, nil

modules/disk-uploader/pkg/vmexport/vmexport_suite_test.go

@@ -3,11 +3,14 @@ package vmexport_test
 import (
 	"testing"
 
+	"github.com/kubevirt/kubevirt-tekton-tasks/modules/shared/pkg/log"
 	. "github.com/onsi/ginkgo/v2"
 	. "github.com/onsi/gomega"
+	"go.uber.org/zap"
 )
 
 func TestVMExport(t *testing.T) {
+	log.InitLogger(zap.InfoLevel)
 	RegisterFailHandler(Fail)
 	RunSpecs(t, "VMExport Suite")
 }

modules/disk-uploader/pkg/vmexport/vmexport_test.go

@@ -114,6 +114,27 @@ var _ = Describe("VMExport", func() {
 		})
 	})
 
+	Describe("WaitUntilVirtualMachineExportSkipped", func() {
+		It("should return error", func() {
+			_, err := vmExportClient.ExportV1beta1().VirtualMachineExports(namespace).Create(context.Background(),
+				&v1beta1.VirtualMachineExport{
+					ObjectMeta: metav1.ObjectMeta{
+						Name:      name,
+						Namespace: namespace,
+					},
+					Status: &v1beta1.VirtualMachineExportStatus{
+						Phase: v1beta1.Skipped,
+					},
+				},
+				metav1.CreateOptions{},
+			)
+			Expect(err).NotTo(HaveOccurred())
+
+			err = vmexport.WaitUntilVirtualMachineExportReady(virtClient, namespace, name)
+			Expect(err).To(HaveOccurred())
+		})
+	})
+
 	Describe("GetRawDiskUrlFromVolumes", func() {
 		Context("when retrieved URL from the VirtualMachineExport volumes", func() {
 			BeforeEach(func() {