Sha256: bdc3af838960545d6b1d4ecc78995c226edbeffa962511b06be61d0dc67a9dda
Contents?: true
Size: 1.61 KB
Versions: 13
Compression:
Stored size: 1.61 KB
Contents
module Dplyr
class Report
attr_reader :hosts, :exit_statuses
def initialize(hosts, exit_statuses, messages)
@hosts = hosts
@exit_statuses = exit_statuses
@messages = messages
end
def print_full
print_successful_jobs
print_failed_jobs
print_summary
end
def succeeded
@succeeded ||= exit_statuses.keys.select do |k|
exit_statuses[k] == 0
end
end
def failed
@failed ||= exit_statuses.keys.select do |k|
exit_statuses[k] != 0
end
end
def print_successful_jobs
puts "succeeded".green
succeeded.each do |host|
messages = @messages[host]
puts " - #{host[:id]}:"
next if not messages.is_a? Array
messages.each { |m| puts " #{m}"}
end
end
def print_failed_jobs
return if failed.count == 0
puts "failed".red
failed.each do |host|
puts " - #{host[:id]}"
end
end
def print_summary
total_hosts = hosts.count
run_count = @exit_statuses.count
not_run = total_hosts - run_count
if (failed.count > 0 || not_run > 0 )
not_run_error = "not run on #{not_run}/#{total_hosts}" if not_run > 0
failed_error = "failed on #{failed.count} of #{total_hosts} hosts" if failed.count > 0
errors = []
errors << not_run_error if not_run_error
errors << failed_error if failed_error
error_str = "task #{errors.join(", ")}"
raise ::Dply::Error, error_str
end
puts "tasks ran successfully on #{succeeded.count}/#{total_hosts} hosts"
end
end
end
Version data entries
13 entries across 13 versions & 1 rubygems