From cb32c9126b494f147aed0a80bdc834449f6cfc52 Mon Sep 17 00:00:00 2001 From: amartynov Date: Tue, 18 Aug 2015 17:53:39 +0300 Subject: [PATCH] out.flush --- devops-service/commands/stack.rb | 5 ++++- devops-service/providers/ec2.rb | 2 ++ devops-service/workers/stack_bootstrap_worker.rb | 1 + 3 files changed, 7 insertions(+), 1 deletion(-) diff --git a/devops-service/commands/stack.rb b/devops-service/commands/stack.rb index 3d54805..d2acb1f 100644 --- a/devops-service/commands/stack.rb +++ b/devops-service/commands/stack.rb @@ -16,13 +16,16 @@ module StackCommands puts stack.stack_status if stack.stack_status != 'CREATE_IN_PROGRESS' mongo.stack_update(stack) - out << "Stack '#{stack.id}' status is now #{stack.stack_status}" + out << "Stack '#{stack.id}' status is now #{stack.stack_status}\n" + out.flush break end out << "Next try...\n" + out.flush end rescue StandardError => e logger.error e.message + out << "Error: #{e.message}\n" return 5 end end diff --git a/devops-service/providers/ec2.rb b/devops-service/providers/ec2.rb index 97b7e51..16c8479 100644 --- a/devops-service/providers/ec2.rb +++ b/devops-service/providers/ec2.rb @@ -211,6 +211,7 @@ module Provider out << "Stack template: #{stack.stack_template}\n" out << "Stack parameters: #{stack.parameters}\n" out << "Stack template: #{stack.template_body}\n" + out.flush response = cloud_formation.create_stack(stack.name, { 'TemplateBody' => stack.template_body, @@ -220,6 +221,7 @@ module Provider ) stack.id = response.body['StackId'] out << "Stack id: #{stack.id}\n" + out.flush rescue Excon::Errors::Conflict => e raise ProviderErrors::NameConflict rescue Excon::Errors::BadRequest => br diff --git a/devops-service/workers/stack_bootstrap_worker.rb b/devops-service/workers/stack_bootstrap_worker.rb index 4278cb9..665ff0c 100644 --- a/devops-service/workers/stack_bootstrap_worker.rb +++ b/devops-service/workers/stack_bootstrap_worker.rb @@ -30,6 +30,7 @@ class StackBootstrapWorker < Worker sync_bootstrap_proc.call(out, stack, mongo) out << "\nStack '#{stack.name}' has been created\n" + out.flush servers = persist_stack_servers!(stack, provider) unless options['stack_attributes']['without_bootstrap'] statuses = servers.map do |s|