diff --git a/pkg/controller/plan/migration.go b/pkg/controller/plan/migration.go
index 4ef55f4cb..e35e62710 100644
--- a/pkg/controller/plan/migration.go
+++ b/pkg/controller/plan/migration.go
@@ -55,36 +55,38 @@ var (
 
 // Phases.
 const (
-	Started                    = "Started"
-	PreHook                    = "PreHook"
-	StorePowerState            = "StorePowerState"
-	PowerOffSource             = "PowerOffSource"
-	WaitForPowerOff            = "WaitForPowerOff"
-	CreateDataVolumes          = "CreateDataVolumes"
-	CreateVM                   = "CreateVM"
-	CopyDisks                  = "CopyDisks"
-	AllocateDisks              = "AllocateDisks"
-	CopyingPaused              = "CopyingPaused"
-	AddCheckpoint              = "AddCheckpoint"
-	AddFinalCheckpoint         = "AddFinalCheckpoint"
-	CreateSnapshot             = "CreateSnapshot"
-	CreateInitialSnapshot      = "CreateInitialSnapshot"
-	CreateFinalSnapshot        = "CreateFinalSnapshot"
-	Finalize                   = "Finalize"
-	CreateGuestConversionPod   = "CreateGuestConversionPod"
-	ConvertGuest               = "ConvertGuest"
-	CopyDisksVirtV2V           = "CopyDisksVirtV2V"
-	PostHook                   = "PostHook"
-	Completed                  = "Completed"
-	WaitForSnapshot            = "WaitForSnapshot"
-	WaitForInitialSnapshot     = "WaitForInitialSnapshot"
-	WaitForFinalSnapshot       = "WaitForFinalSnapshot"
-	ConvertOpenstackSnapshot   = "ConvertOpenstackSnapshot"
-	StoreSnapshotDeltas        = "StoreSnapshotDeltas"
-	StoreInitialSnapshotDeltas = "StoreInitialSnapshotDeltas"
-	RemovePreviousSnapshot     = "RemovePreviousSnapshot"
-	RemovePenultimateSnapshot  = "RemovePenultimateSnapshot"
-	RemoveFinalSnapshot        = "RemoveFinalSnapshot"
+	Started                       = "Started"
+	PreHook                       = "PreHook"
+	StorePowerState               = "StorePowerState"
+	PowerOffSource                = "PowerOffSource"
+	WaitForPowerOff               = "WaitForPowerOff"
+	CreateDataVolumes             = "CreateDataVolumes"
+	WaitForDataVolumesStatus      = "WaitForDataVolumesStatus"
+	WaitForFinalDataVolumesStatus = "WaitForFinalDataVolumesStatus"
+	CreateVM                      = "CreateVM"
+	CopyDisks                     = "CopyDisks"
+	AllocateDisks                 = "AllocateDisks"
+	CopyingPaused                 = "CopyingPaused"
+	AddCheckpoint                 = "AddCheckpoint"
+	AddFinalCheckpoint            = "AddFinalCheckpoint"
+	CreateSnapshot                = "CreateSnapshot"
+	CreateInitialSnapshot         = "CreateInitialSnapshot"
+	CreateFinalSnapshot           = "CreateFinalSnapshot"
+	Finalize                      = "Finalize"
+	CreateGuestConversionPod      = "CreateGuestConversionPod"
+	ConvertGuest                  = "ConvertGuest"
+	CopyDisksVirtV2V              = "CopyDisksVirtV2V"
+	PostHook                      = "PostHook"
+	Completed                     = "Completed"
+	WaitForSnapshot               = "WaitForSnapshot"
+	WaitForInitialSnapshot        = "WaitForInitialSnapshot"
+	WaitForFinalSnapshot          = "WaitForFinalSnapshot"
+	ConvertOpenstackSnapshot      = "ConvertOpenstackSnapshot"
+	StoreSnapshotDeltas           = "StoreSnapshotDeltas"
+	StoreInitialSnapshotDeltas    = "StoreInitialSnapshotDeltas"
+	RemovePreviousSnapshot        = "RemovePreviousSnapshot"
+	RemovePenultimateSnapshot     = "RemovePenultimateSnapshot"
+	RemoveFinalSnapshot           = "RemoveFinalSnapshot"
 )
 
 // Steps.
@@ -134,6 +136,7 @@ var (
 			{Name: WaitForInitialSnapshot},
 			{Name: StoreInitialSnapshotDeltas, All: VSphere},
 			{Name: CreateDataVolumes},
+			{Name: WaitForDataVolumesStatus},
 			{Name: CopyDisks},
 			{Name: CopyingPaused},
 			{Name: RemovePreviousSnapshot, All: VSphere},
@@ -148,6 +151,7 @@ var (
 			{Name: CreateFinalSnapshot},
 			{Name: WaitForFinalSnapshot},
 			{Name: AddFinalCheckpoint},
+			{Name: WaitForFinalDataVolumesStatus},
 			{Name: Finalize},
 			{Name: RemoveFinalSnapshot, All: VSphere},
 			{Name: CreateGuestConversionPod, All: RequiresConversion},
@@ -662,9 +666,9 @@ func (r *Migration) step(vm *plan.VMStatus) (step string) {
 		step = Initialize
 	case AllocateDisks:
 		step = DiskAllocation
-	case CopyDisks, CopyingPaused, RemovePreviousSnapshot, CreateSnapshot, WaitForSnapshot, StoreSnapshotDeltas, AddCheckpoint, ConvertOpenstackSnapshot:
+	case CopyDisks, CopyingPaused, RemovePreviousSnapshot, CreateSnapshot, WaitForSnapshot, StoreSnapshotDeltas, AddCheckpoint, ConvertOpenstackSnapshot, WaitForDataVolumesStatus:
 		step = DiskTransfer
-	case RemovePenultimateSnapshot, CreateFinalSnapshot, WaitForFinalSnapshot, AddFinalCheckpoint, Finalize, RemoveFinalSnapshot:
+	case RemovePenultimateSnapshot, CreateFinalSnapshot, WaitForFinalSnapshot, AddFinalCheckpoint, Finalize, RemoveFinalSnapshot, WaitForFinalDataVolumesStatus:
 		step = Cutover
 	case CreateGuestConversionPod, ConvertGuest:
 		step = ImageConversion
@@ -1039,6 +1043,22 @@ func (r *Migration) execute(vm *plan.VMStatus) (err error) {
 		if ready {
 			vm.Phase = r.next(vm.Phase)
 		}
+	case WaitForDataVolumesStatus, WaitForFinalDataVolumesStatus:
+		step, found := vm.FindStep(r.step(vm))
+		if !found {
+			vm.AddError(fmt.Sprintf("Step '%s' not found", r.step(vm)))
+			break
+		}
+
+		dvs, err := r.kubevirt.getDVs(vm)
+		if err != nil {
+			step.AddError(err.Error())
+			err = nil
+			break
+		}
+		if !r.hasPausedDv(dvs) {
+			vm.Phase = r.next(vm.Phase)
+		}
 	case StoreInitialSnapshotDeltas, StoreSnapshotDeltas:
 		step, found := vm.FindStep(r.step(vm))
 		if !found {
@@ -1073,9 +1093,9 @@ func (r *Migration) execute(vm *plan.VMStatus) (err error) {
 
 		switch vm.Phase {
 		case AddCheckpoint:
-			vm.Phase = CopyDisks
+			vm.Phase = WaitForDataVolumesStatus
 		case AddFinalCheckpoint:
-			vm.Phase = Finalize
+			vm.Phase = WaitForFinalDataVolumesStatus
 		}
 	case StorePowerState:
 		step, found := vm.FindStep(r.step(vm))
@@ -1259,6 +1279,15 @@ func (r *Migration) execute(vm *plan.VMStatus) (err error) {
 	return
 }
 
+func (r *Migration) hasPausedDv(dvs []ExtendedDataVolume) bool {
+	for _, dv := range dvs {
+		if dv.Status.Phase == Paused {
+			return true
+		}
+	}
+	return false
+}
+
 func (r *Migration) resetPrecopyTasks(vm *plan.VMStatus, step *plan.Step) {
 	step.Completed = nil
 	for _, task := range step.Tasks {