fix

Author: universal-itengineer

test/e2e/internal/util/vm.go

@@ -32,6 +32,7 @@ import (
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/types"
 	"k8s.io/apimachinery/pkg/util/wait"
+	"k8s.io/utils/ptr"
 	virtv1 "kubevirt.io/api/core/v1"
 	"sigs.k8s.io/controller-runtime/pkg/client"
 
@@ -132,7 +133,7 @@ func WaitUntilConditionOrSkipKnownVDMigrationControllerRevert(timeout time.Durat
 	ctx, cancel := context.WithTimeout(context.Background(), timeout)
 	defer cancel()
 
-	err := wait.PollUntilContextTimeout(ctx, time.Second, timeout, true, func(context.Context) (bool, error) {
+	err := wait.PollUntilContextCancel(ctx, time.Second, true, func(context.Context) (bool, error) {
 		lastErr = condition()
 		return lastErr == nil, nil
 	})
@@ -148,7 +149,7 @@ func WaitUntilConditionOrSkipKnownVDMigrationControllerRevert(timeout time.Durat
 		Fail(fmt.Sprintf("timed out waiting for condition: %v", lastErr))
 	}
 
-	Expect(err).NotTo(HaveOccurred())
+	Fail(fmt.Sprintf("unexpected poll error without condition failure: %v", err))
 }
 
 func SkipIfKnownVDMigrationControllerRevertOnTimeout(namespace string, since time.Time) {
@@ -190,6 +191,7 @@ func findKnownVDMigrationControllerRevertLog(namespace string, since time.Time)
 		stream, err := framework.GetClients().KubeClient().CoreV1().Pods(pod.Namespace).GetLogs(pod.Name, &corev1.PodLogOptions{
 			Container: controller.VirtualizationController,
 			SinceTime: &sinceTime,
+			TailLines: ptr.To(int64(5000)),
 		}).Stream(ctx)
 		if err != nil {
 			GinkgoWriter.Printf("Failed to read virtualization-controller logs from pod %s: %v\n", pod.Name, err)