flush output

This commit is contained in:
Anton Chuchkalov 2016-08-12 14:31:58 +03:00
parent 72ff757e7b
commit e8eedc1092

View File

@ -19,11 +19,11 @@ class WaitRebootstrapWorker < Worker
old_node_info = options.fetch('old_chef_node') old_node_info = options.fetch('old_chef_node')
out.puts(JSON.pretty_generate(old_node_info)) out.puts(JSON.pretty_generate(old_node_info))
out.puts("Waiting for bootstrap end...") puts_and_flush "Waiting for bootstrap end..."
Devops::Helpers::JobWaiter.new(options["jid"], 10*60).wait Devops::Helpers::JobWaiter.new(options["jid"], 10*60).wait
out.puts("Setting run list to #{old_node_info['run_list']}") puts_and_flush "Setting run list to #{old_node_info['run_list']}"
executor = Devops::Executor::ServerExecutor.new(server, out, current_user: owner) executor = Devops::Executor::ServerExecutor.new(server, out, current_user: owner)
executor.set_run_list(old_node_info["run_list"]) executor.set_run_list(old_node_info["run_list"])