#891: events output to log
This commit is contained in:
parent
126caa2682
commit
645e0cbf24
@ -21,10 +21,16 @@ module StackCommands
|
|||||||
|
|
||||||
begin
|
begin
|
||||||
out << "Syncing stack '#{stack.id}'...\n"
|
out << "Syncing stack '#{stack.id}'...\n"
|
||||||
|
events_keys = []
|
||||||
sleep_times.each do |sleep_time|
|
sleep_times.each do |sleep_time|
|
||||||
sleep sleep_time
|
sleep sleep_time
|
||||||
stack.sync_details!
|
stack.sync_details!
|
||||||
out.puts stack.events.inspect
|
stack.events.each do |event|
|
||||||
|
unless events_keys.include?(event["event_id"])
|
||||||
|
events_keys << event["event_id"]
|
||||||
|
out.puts "#{event["status"]}: #{event["reason"]}"
|
||||||
|
end
|
||||||
|
end
|
||||||
case stack.stack_status
|
case stack.stack_status
|
||||||
when 'CREATE_IN_PROGRESS'
|
when 'CREATE_IN_PROGRESS'
|
||||||
out << "."
|
out << "."
|
||||||
|
|||||||
@ -295,7 +295,7 @@ module Provider
|
|||||||
end
|
end
|
||||||
|
|
||||||
def stack_events(stack)
|
def stack_events(stack)
|
||||||
cloud_formation.describe_stack_events(stack.name).body['StackEvents'].map{|se| {"stack_name" => se["StackName"], "stack_id" => se["StackId"], "event_id" => se["EventId"], "reason" => se["ResourceStatusReason"]}}
|
cloud_formation.describe_stack_events(stack.name).body['StackEvents'].map{|se| {"stack_name" => se["StackName"], "stack_id" => se["StackId"], "event_id" => se["EventId"], "reason" => se["ResourceStatusReason"], "status" => se["ResourceStatus"]}}
|
||||||
end
|
end
|
||||||
|
|
||||||
# не работает, не используется
|
# не работает, не используется
|
||||||
|
|||||||
@ -91,6 +91,7 @@ class Worker
|
|||||||
self.out = out
|
self.out = out
|
||||||
|
|
||||||
job_result = yield(out, file)
|
job_result = yield(out, file)
|
||||||
|
out.puts "TODO: job_result: #{job_result}"
|
||||||
canonical_status = (job_result == 0 ? STATUS::COMPLETED : STATUS::FAILED)
|
canonical_status = (job_result == 0 ? STATUS::COMPLETED : STATUS::FAILED)
|
||||||
update_job_status(canonical_status, job_result)
|
update_job_status(canonical_status, job_result)
|
||||||
rescue StandardError, RecordNotFound => e
|
rescue StandardError, RecordNotFound => e
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user