diff --git a/tests/datavolume_test.go b/tests/datavolume_test.go
index b794b4427e..c5931afdfb 100644
--- a/tests/datavolume_test.go
+++ b/tests/datavolume_test.go
@@ -1126,7 +1126,7 @@ var _ = Describe("[vendor:cnv-qe@redhat.com][level:component]DataVolume tests",
 				size:             "1Gi",
 				url:              vcenterURL,
 				dvFunc:           createVddkDataVolume,
-				eventReason:      common.AwaitingVDDK,
+				eventReason:      "Pending",
 				phase:            cdiv1.ImportScheduled,
 				checkPermissions: false,
 				readyCondition: &cdiv1.DataVolumeCondition{
@@ -1139,6 +1139,12 @@ var _ = Describe("[vendor:cnv-qe@redhat.com][level:component]DataVolume tests",
 					Message: fmt.Sprintf("waiting for %s configmap or %s annotation for VDDK image", common.VddkConfigMap, controller.AnnVddkInitImageURL),
 					Reason:  common.AwaitingVDDK,
 				},
+				boundConditionWithPopulators: &cdiv1.DataVolumeCondition{
+					Type:    cdiv1.DataVolumeBound,
+					Status:  v1.ConditionFalse,
+					Message: "PVC dv-awaiting-vddk Pending",
+					Reason:  "Pending",
+				},
 				runningCondition: &cdiv1.DataVolumeCondition{
 					Type:   cdiv1.DataVolumeRunning,
 					Status: v1.ConditionFalse,
diff --git a/tests/import_test.go b/tests/import_test.go
index 0593f0e5eb..db0a2f8f14 100644
--- a/tests/import_test.go
+++ b/tests/import_test.go
@@ -182,6 +182,22 @@ var _ = Describe("[rfe_id:1115][crit:high][vendor:cnv-qe@redhat.com][level:compo
 		}
 	})
 
+	It("Should do multi-stage importer pods with populator flow", func() {
+		vcenterURL := fmt.Sprintf(utils.VcenterURL, f.CdiInstallNs)
+		dataVolume := f.CreateVddkWarmImportDataVolume("import-pod-retain-test", "100Mi", vcenterURL)
+		By(fmt.Sprintf("Create new datavolume %s", dataVolume.Name))
+		dataVolume, err := utils.CreateDataVolumeFromDefinition(f.CdiClient, f.Namespace.Name, dataVolume)
+		Expect(err).ToNot(HaveOccurred())
+
+		By("Verify pvc was created")
+		pvc, err := utils.WaitForPVC(f.K8sClient, dataVolume.Namespace, dataVolume.Name)
+		Expect(err).ToNot(HaveOccurred())
+		f.ForceBindIfWaitForFirstConsumer(pvc)
+
+		By("Wait for import to be completed")
+		err = utils.WaitForDataVolumePhase(f, dataVolume.Namespace, cdiv1.Succeeded, dataVolume.Name)
+		Expect(err).ToNot(HaveOccurred(), "Datavolume not in phase succeeded in time")
+	})
 })
 
 var _ = Describe("DataVolume Garbage Collection", func() {