Index: /branches/amp_3_7_2/scripts/import_es_snapshot.sh
===================================================================
--- /branches/amp_3_7_2/scripts/import_es_snapshot.sh	(revision 2851)
+++ /branches/amp_3_7_2/scripts/import_es_snapshot.sh	(working copy)
@@ -95,9 +95,6 @@
 # -----------------------------------------------
 # STEP 3 — Copy snapshot directory from remote AMP
 # -----------------------------------------------
-# -----------------------------------------------
-# STEP 3 — Copy snapshot directory from remote AMP
-# -----------------------------------------------
 log "[3/9] Copying snapshot directory..."
 
 RSYNC_OUTPUT=$(sshpass -p "$AMP_PASS" rsync -avz \
\ No newline at end of file
@@ -129,7 +126,12 @@
             fail "Remote copy failed (rsync and scp)"
     fi
 fi
+
+log "Fixing snapshot directory ownership after rsync..."
 
+chown -R elasticsearch:elasticsearch "$LOCAL_SNAPSHOT_DIR"
+chmod -R 755 "$LOCAL_SNAPSHOT_DIR"
+
 # ----------------------------------------------------------
 # STEP 4 — Set path.repo and restart Elasticsearch
 # ----------------------------------------------------------
\ No newline at end of file
Index: /branches/amp_3_7_2/src/webui/webui/htdocs/new/src/hive/controller/snapshot_controller.py
===================================================================
--- /branches/amp_3_7_2/src/webui/webui/htdocs/new/src/hive/controller/snapshot_controller.py	(revision 2851)
+++ /branches/amp_3_7_2/src/webui/webui/htdocs/new/src/hive/controller/snapshot_controller.py	(working copy)
@@ -59,7 +59,9 @@
         if body.get("ip"):
             # username + password required
             if not body.get("username") or not body.get("password"):
-                return json_response({"status": "Failed", "message": "username and password are required when ip is provided"}, status=400)
+                return json_response(
+                    {"status": "Failed", "message": "username and password are required when ip is provided"},
+                    status=400)
 
             if body.get("location") == 'custom':
                 if body.get("path") is None:
@@ -76,7 +78,7 @@
         error_msg = result.get("error") or result.get("stderr") or result.get("stdout") or ""
 
         if result.get("return_code") == 0:
-            return json_response({"status": "Successful", "message": "Snapshot export completed successfully"})
+            return json_response({"status": "Started", "message": "Snapshot export job started successfully"})
         elif result.get("return_code") == 1:
             oper_log("error", "system", "Error exporting snapshot: %s" % str(error_msg))
             return json_response({"status": "Failed",
@@ -95,7 +97,6 @@
 # IMPORT
 # ============================================================
 def import_snapshot(request):
-
     try:
         try:
             body = json.loads(request.body)
@@ -136,7 +137,7 @@
         error_msg = result.get("error") or result.get("stderr") or result.get("stdout") or ""
 
         if result.get("return_code") == 0:
-            return json_response({"status": "Successful", "message": "Snapshot import completed successfully"})
+            return json_response({"status": "Started", "message": "Snapshot import job started successfully"})
         elif result.get("return_code") == 1:
             oper_log("error", "system", "Error importing snapshot: %s" % str(error_msg))
             return json_response({"status": "Failed",
Index: /branches/amp_3_7_2/src/webui/webui/htdocs/new/src/hive/services/snapshot_service.py
===================================================================
--- /branches/amp_3_7_2/src/webui/webui/htdocs/new/src/hive/services/snapshot_service.py	(revision 2851)
+++ /branches/amp_3_7_2/src/webui/webui/htdocs/new/src/hive/services/snapshot_service.py	(working copy)
@@ -35,20 +35,10 @@
     @staticmethod
     def _run(cmd):
         try:
-            proc = subprocess.Popen(cmd, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
-            out, err = proc.communicate()
+            subprocess.Popen(cmd, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
 
-            try:
-                out = out.decode()
-            except:
-                pass
-            try:
-                err = err.decode()
-            except:
-                pass
+            return {"return_code": 0, "status": "started"}
 
-            return {"return_code": proc.returncode, "stdout": out, "stderr": err}
-
         except Exception as e:
             return {"return_code": 1, "error": str(e)}