diff --git a/engine/storage/datamotion/src/main/java/org/apache/cloudstack/storage/motion/AncientDataMotionStrategy.java b/engine/storage/datamotion/src/main/java/org/apache/cloudstack/storage/motion/AncientDataMotionStrategy.java
index 7c930fb34c9..c49ffba0b82 100644
--- a/engine/storage/datamotion/src/main/java/org/apache/cloudstack/storage/motion/AncientDataMotionStrategy.java
+++ b/engine/storage/datamotion/src/main/java/org/apache/cloudstack/storage/motion/AncientDataMotionStrategy.java
@@ -356,37 +356,47 @@ public class AncientDataMotionStrategy implements DataMotionStrategy {
             DataObject objOnImageStore = imageStore.create(srcData);
             objOnImageStore.processEvent(Event.CreateOnlyRequested);
 
-            Answer answer = copyObject(srcData, objOnImageStore);
-            if (answer == null || !answer.getResult()) {
-                if (answer != null) {
-                    s_logger.debug("copy to image store failed: " + answer.getDetails());
+            Answer answer = null;
+            try {
+                answer = copyObject(srcData, objOnImageStore);
+
+                if (answer == null || !answer.getResult()) {
+                    if (answer != null) {
+                        s_logger.debug("copy to image store failed: " + answer.getDetails());
+                    }
+                    objOnImageStore.processEvent(Event.OperationFailed);
+                    imageStore.delete(objOnImageStore);
+                    return answer;
                 }
-                objOnImageStore.processEvent(Event.OperationFailed);
-                imageStore.delete(objOnImageStore);
-                return answer;
-            }
 
-            objOnImageStore.processEvent(Event.OperationSuccessed, answer);
+                objOnImageStore.processEvent(Event.OperationSuccessed, answer);
 
-            objOnImageStore.processEvent(Event.CopyingRequested);
+                objOnImageStore.processEvent(Event.CopyingRequested);
 
-            CopyCommand cmd = new CopyCommand(objOnImageStore.getTO(), addFullCloneFlagOnVMwareDest(destData.getTO()), _copyvolumewait, VirtualMachineManager.ExecuteInSequence.value());
-            EndPoint ep = selector.select(objOnImageStore, destData);
-            if (ep == null) {
-                String errMsg = "No remote endpoint to send command, check if host or ssvm is down?";
-                s_logger.error(errMsg);
-                answer = new Answer(cmd, false, errMsg);
-            } else {
-                answer = ep.sendMessage(cmd);
-            }
-
-            if (answer == null || !answer.getResult()) {
-                if (answer != null) {
-                    s_logger.debug("copy to primary store failed: " + answer.getDetails());
+                CopyCommand cmd = new CopyCommand(objOnImageStore.getTO(), addFullCloneFlagOnVMwareDest(destData.getTO()), _copyvolumewait, VirtualMachineManager.ExecuteInSequence.value());
+                EndPoint ep = selector.select(objOnImageStore, destData);
+                if (ep == null) {
+                    String errMsg = "No remote endpoint to send command, check if host or ssvm is down?";
+                    s_logger.error(errMsg);
+                    answer = new Answer(cmd, false, errMsg);
+                } else {
+                    answer = ep.sendMessage(cmd);
                 }
-                objOnImageStore.processEvent(Event.OperationFailed);
-                imageStore.delete(objOnImageStore);
-                return answer;
+
+                if (answer == null || !answer.getResult()) {
+                    if (answer != null) {
+                        s_logger.debug("copy to primary store failed: " + answer.getDetails());
+                    }
+                    objOnImageStore.processEvent(Event.OperationFailed);
+                    imageStore.delete(objOnImageStore);
+                    return answer;
+                }
+            } catch (Exception e) {
+                if (imageStore.exists(objOnImageStore)) {
+                    objOnImageStore.processEvent(Event.OperationFailed);
+                    imageStore.delete(objOnImageStore);
+                }
+                throw e;
             }
 
             objOnImageStore.processEvent(Event.OperationSuccessed);