Asynchronous push_to_storage for files and images

pillar/application/modules/file_storage/__init__.py

@@ -199,7 +199,9 @@ def process_file(src_file):
     if mime_type != 'video':
         # Sync the whole subdir
         sync_path = os.path.split(file_abs_path)[0]
-        push_to_storage(str(src_file['project']), sync_path)
+        # push_to_storage(str(src_file['project']), sync_path)
+        p = Process(target=push_to_storage, args=(str(src_file['project']), sync_path))
+        p.start()
     else:
         sync_path = file_abs_path
 

pillar/application/utils/storage.py

@@ -75,7 +75,6 @@ def push_to_storage(project_id, full_path, backend='cgs'):
             for root, dirs, files in os.walk(full_path):
                 for name in files:
                     push_single_file(project_id, os.path.join(root, name), backend)
-
         else:
             raise IOError('ERROR: path not found')