chore(scale): prohibit scale when there is a running pipeline

Author: duanhongyi

rootfs/api/models/app.py

@@ -221,15 +221,14 @@ def restart(self, **kwargs):  # noqa
 
     def scale(self, user, structure):
         err_msg = None
-        if (PROCFILE_TYPE_RUN in structure or
-                self.release_set.filter(failed=False).latest().build is None):
+        release = self.release_set.filter(failed=False).latest()
+        if (PROCFILE_TYPE_RUN in structure or release.build is None):
             if PROCFILE_TYPE_RUN in structure:
                 err_msg = 'Cannot set scale for reserved types, procfile type is: run'
             else:
                 err_msg = 'No build associated with this release'
             self.log(err_msg, logging.WARNING)
             raise DryccException(err_msg)
-        release = self.release_set.filter(failed=False).latest()
         app_settings = self.appsettings_set.latest()
         if release.canary:
             self._scale(

rootfs/api/views.py

@@ -253,6 +253,10 @@ def list(self, request, *args, **kwargs):
         return Response(serializer.data)
 
     def scale(self, request, **kwargs):
+        app = self.get_object()
+        release = app.release_set.filter(failed=False).latest()
+        if release.build is not None and release.state == "created":
+            raise DryccException('There is an executing pipeline, please wait')
         scale_app.delay(self.get_object(), request.user, request.data)
         return Response(status=status.HTTP_204_NO_CONTENT)
 
@@ -358,6 +362,8 @@ def post_save(self, config):
                 self.request.user, config=config, build=release.build, canary=release.canary)
             # It's possible to set config values before a build
             if release.build is not None:
+                if release.state == "created":
+                    raise DryccException('There is an executing pipeline, please wait')
                 config.app.deploy(release)
             release.state = "succeed"
             release.save()