#855: cid:priority

devops-service/providers/ec2.rb

@@ -323,6 +323,7 @@ module Provider
           'key_name' => instance["keyName"],
           'private_ip' => instance["privateIpAddress"],
           'public_ip' => instance["ipAddress"],
+          'tags' => instance["tagSet"]
         }
       end
     end

devops-service/workers/stack_bootstrap_worker.rb

@@ -26,9 +26,15 @@ class StackBootstrapWorker < Worker
         return 1
       end
 
+      #TODO: errors
       begin
-        servers = persist_stack_servers!(stack)
+        servers_with_priority = persist_stack_servers!(stack)
-        bootstrap_servers!(servers, report) unless without_bootstrap
+        unless without_bootstrap
+          sorted_keys = servers_with_priority.keys.sort{|x,y| y <=> x}
+          sorted_keys.each do |key|
+            bootstrap_servers!(servers_with_priority[key], report)
+          end
+        end
       rescue BootstrapingStackServerError
         @out.puts "\nAn error occured during bootstraping stack servers. Initiating stack rollback."
         rollback_stack!(stack)
@@ -75,7 +81,7 @@ class StackBootstrapWorker < Worker
   def bootstrap_servers!(servers, report)
     @out << "\nStart bootstraping stack servers\n"
 
-    report.subreports = subreports = []
+    subreports = []
     data = {}
     servers.each do |server|
       sjid = Worker.start_async(BootstrapWorker,
@@ -153,6 +159,10 @@ class StackBootstrapWorker < Worker
     report
   end
 
+  # returns
+  # {
+  #   "priority" => [Servers]
+  # }
   def persist_stack_servers!(stack)
     @out.puts "Start syncing stack servers with CID"
     @out.flush
@@ -160,7 +170,10 @@ class StackBootstrapWorker < Worker
     deploy_env = project.deploy_env(stack.deploy_env)
     provider = stack.provider_instance
 
-    servers = provider.stack_servers(stack).map do |extended_info|
+    stack_servers_info = provider.stack_servers(stack).group_by{|info| info["tags"]["cid:priority"] || 0}
+    stack_servers_with_priority = {}
+    stack_servers_info.each do |priority, info_array|
+      stack_servers_with_priority[priority] = info_array.map do |extended_info|
         server_attrs = {
           'provider' => provider.name,
           'project' => project.id,
@@ -181,9 +194,13 @@ class StackBootstrapWorker < Worker
         # server.chef_node_name =  provider.create_default_chef_node_name(server)
         server
       end
+    end
     @out.puts "Stack servers have been synced with CID"
+    stack_servers_info.each do |priority, servers|
+      @out.puts "Priority '#{priority}': #{servers.map(&:id).join(", ")}"
+    end
     @out.flush
-    servers
+    stack_servers_with_priority
   end
 
 end