diff --git a/engine/orchestration/src/com/cloud/vm/VirtualMachineManagerImpl.java b/engine/orchestration/src/com/cloud/vm/VirtualMachineManagerImpl.java
index 30184890051..9dea90a41d1 100644
--- a/engine/orchestration/src/com/cloud/vm/VirtualMachineManagerImpl.java
+++ b/engine/orchestration/src/com/cloud/vm/VirtualMachineManagerImpl.java
@@ -4297,7 +4297,7 @@ public class VirtualMachineManagerImpl extends ManagerBase implements VirtualMac
             workJob = new VmWorkJobVO(context.getContextId());
 
             workJob.setDispatcher(VmWorkConstants.VM_WORK_JOB_DISPATCHER);
-            workJob.setCmd(VmWorkMigrate.class.getName());
+            workJob.setCmd(VmWorkMigrateWithStorage.class.getName());
 
             workJob.setAccountId(account.getId());
             workJob.setUserId(user.getId());
@@ -4340,7 +4340,7 @@ public class VirtualMachineManagerImpl extends ManagerBase implements VirtualMac
             workJob = new VmWorkJobVO(context.getContextId());
 
             workJob.setDispatcher(VmWorkConstants.VM_WORK_JOB_DISPATCHER);
-            workJob.setCmd(VmWorkMigrate.class.getName());
+            workJob.setCmd(VmWorkMigrateForScale.class.getName());
 
             workJob.setAccountId(account.getId());
             workJob.setUserId(user.getId());
diff --git a/engine/orchestration/src/com/cloud/vm/VmWorkMigrateForScale.java b/engine/orchestration/src/com/cloud/vm/VmWorkMigrateForScale.java
index 0dd4d88c218..2147a54a4ca 100644
--- a/engine/orchestration/src/com/cloud/vm/VmWorkMigrateForScale.java
+++ b/engine/orchestration/src/com/cloud/vm/VmWorkMigrateForScale.java
@@ -18,30 +18,18 @@ package com.cloud.vm;
 
 import com.cloud.deploy.DeployDestination;
 
-public class VmWorkMigrateForScale extends VmWork {
+public class VmWorkMigrateForScale extends VmWorkMigrate {
     private static final long serialVersionUID = 6854870395568389613L;
 
-    long srcHostId;
-    DeployDestination deployDestination;
     Long newSvcOfferingId;
 
     public VmWorkMigrateForScale(long userId, long accountId, long vmId, String handlerName, long srcHostId,
             DeployDestination dest, Long newSvcOfferingId) {
 
-        super(userId, accountId, vmId, handlerName);
-        this.srcHostId = srcHostId;
-        deployDestination = dest;
+        super(userId, accountId, vmId, handlerName, srcHostId, dest);
         this.newSvcOfferingId = newSvcOfferingId;
     }
 
-    public long getSrcHostId() {
-        return srcHostId;
-    }
-
-    public DeployDestination getDeployDestination() {
-        return deployDestination;
-    }
-
     public Long getNewServiceOfferringId() {
         return newSvcOfferingId;
     }