fix(app): deploy applications on Controller start to create RCs and Pods

Fixes #541

Author: helgi

rootfs/api/management/commands/load_db_state_to_k8s.py

@@ -9,8 +9,8 @@ class Command(BaseCommand):
     to k8s.
     """
     def handle(self, *args, **options):
-        """Publishes Deis platform state from the database to etcd."""
-        print("Publishing DB state to k8s...")
+        """Publishes Deis platform state from the database to kubernetes."""
+        print("Publishing DB state to kubernetes...")
         for model in (Key, App, Domain, Certificate, Config):
             for obj in model.objects.all():
                 obj.save()
@@ -21,4 +21,10 @@ def handle(self, *args, **options):
                 domain = get_object_or_404(Domain, domain=domain)
                 cert.attach_in_kubernetes(domain)
 
-        print("Done Publishing DB state to k8s.")
+        # deploy applications
+        print("Deploying available applications")
+        for application in App.objects.all():
+            rel = application.release_set.latest()
+            application.deploy(rel)
+
+        print("Done Publishing DB state to kubernetes.")

rootfs/api/models/app.py

@@ -329,7 +329,7 @@ def _scale_pods(self, scale_types):
                 log_event(self, err, logging.ERROR)
                 raise
 
-    def deploy(self, user, release):
+    def deploy(self, release):
         """Deploy a new release to this application"""
         if release.build is None:
             raise EnvironmentError('No build associated with this release')

rootfs/api/models/build.py

@@ -41,7 +41,7 @@ def create(self, user, *args, **kwargs):
         )
 
         try:
-            self.app.deploy(user, new_release)
+            self.app.deploy(new_release)
             return new_release
         except Exception:
             if 'new_release' in locals():

rootfs/api/models/release.py

@@ -141,7 +141,7 @@ def rollback(self, user, version):
 
         try:
             if self.build is not None:
-                self.app.deploy(user, new_release)
+                self.app.deploy(new_release)
             return new_release
         except Exception:
             if 'new_release' in locals():

rootfs/api/views.py

@@ -304,7 +304,7 @@ def post_save(self, config):
         try:
             # It's possible to set config values before a build
             if self.release.build is not None:
-                config.app.deploy(self.request.user, self.release)
+                config.app.deploy(self.release)
         except Exception:
             self.release.delete()
             raise

rootfs/scheduler/__init__.py

@@ -336,14 +336,21 @@ def __init__(self):
         session.verify = False
         self.session = session
 
-    def deploy(self, namespace, name, image, command, **kwargs):
+    def deploy(self, namespace, name, image, command, **kwargs):  # noqa
         logger.debug('deploy {}, img {}, params {}, cmd "{}"'.format(name, image, kwargs, command))
         app_type = kwargs.get('app_type')
         routable = kwargs.get('routable', False)
 
         # Fetch old RC and create the new one for a release
         old_rc = self._get_old_rc(namespace, app_type)
-        new_rc = self._create_rc(namespace, name, image, command, **kwargs)
+
+        # If an RC already exists then stop processing of the deploy
+        try:
+            self._get_rc(namespace, name)
+            logger.debug('RC {} already exists under Namespace {}. Stopping deploy'.format(name, namespace))  # noqa
+            return
+        except KubeHTTPException:
+            new_rc = self._create_rc(namespace, name, image, command, **kwargs)
 
         # Get the desired number to scale to
         if old_rc: