class DTK::Client::TaskStatus::StreamMode::Element::HierarchicalTask::Results

Constants

ErrorRenderOpts

Attributes

errors[R]

Public Class Methods

new(element, hash) click to toggle source
Calls superclass method
# File lib/task_status/stream_mode/element/hierarchical_task/result.rb, line 25
def initialize(element, hash)
  super
  @errors = hash['errors'] || []
end
render(element, stage_subtasks) click to toggle source
# File lib/task_status/stream_mode/element/hierarchical_task/result.rb, line 31
def self.render(element, stage_subtasks)
  results_per_node = base_subtasks(element, stage_subtasks)
  return if results_per_node.empty?
  # assumption is that if multipe results_per_node they are same type
  results_per_node.first.render_results(results_per_node)
end

Protected Instance Methods

render_error_line(line, opts = {}) click to toggle source
# File lib/task_status/stream_mode/element/hierarchical_task/result.rb, line 65
def render_error_line(line, opts = {})
  render_line(line, ErrorRenderOpts.merge(opts))
end
render_errors(results_per_node) click to toggle source
# File lib/task_status/stream_mode/element/hierarchical_task/result.rb, line 42
def render_errors(results_per_node)
  return unless results_per_node.find { |result| not result.errors.empty?}
  first_time = true
  results_per_node.each do |result| 
    if first_time
      render_line 'ERRORS:' 
      first_time = false
    end
    result.render_node_errors  
  end
end
render_node_errors() click to toggle source
# File lib/task_status/stream_mode/element/hierarchical_task/result.rb, line 54
def render_node_errors
  return if @errors.empty?
  render_node_term
  @errors.each do |error| 
    if err_msg = error['message']
      render_error_line err_msg  
      render_empty_line
    end
  end
end