chore(controller): async mount

Author: duanhongyi

rootfs/api/tasks.py

@@ -89,3 +89,21 @@ def restart_app(app, **kwargs):
         raise e
     else:
         signals.request_finished.send(sender=task_id)
+
+
+@shared_task(
+    autoretry_for=(ServiceUnavailable, ),
+    retry_jitter=True,
+    retry_kwargs={'max_retries': 3}
+)
+def mount_app(app, user, volume):
+    task_id = uuid.uuid4().hex
+    signals.request_started.send(sender=task_id)
+    try:
+        app.mount(user, volume)
+        volume.save()
+    except Exception as e:
+        signals.got_request_exception.send(sender=task_id)
+        raise e
+    else:
+        signals.request_finished.send(sender=task_id)

rootfs/api/views.py

@@ -19,7 +19,7 @@
 from rest_framework.viewsets import GenericViewSet
 
 from api import monitor, models, permissions, serializers, viewsets, authentication
-from api.tasks import scale_app, restart_app
+from api.tasks import scale_app, restart_app, mount_app
 from api.exceptions import AlreadyExists, ServiceUnavailable, DryccException, \
     UnprocessableEntity
 
@@ -761,11 +761,9 @@ def path(self, request, *args, **kwargs):
                 path.pop(key)
             else:
                 path[key] = value
-
         app = self.get_app()
-        volume.path = path  # after merge path
-        app.mount(self.request.user, volume)
-        volume.save()
+        volume.path = path  # volume save by task success
+        mount_app.delay(app, self.request.user, volume)
         serializer = self.get_serializer(volume, many=False)
         return Response(serializer.data)