class Proxy::Dynflow::TaskLauncher::Batch

Public Instance Methods

child_launcher(parent) click to toggle source
# File lib/smart_proxy_dynflow/task_launcher/batch.rb, line 24
def child_launcher(parent)
  Single.new(world, callback, :parent => parent)
end
launch!(input) click to toggle source
# File lib/smart_proxy_dynflow/task_launcher/batch.rb, line 6
def launch!(input)
  plan = trigger(nil, action_class, self, input)
  results[:parent] = format_result(plan)
end
launch_children(parent, input_hash) click to toggle source
# File lib/smart_proxy_dynflow/task_launcher/batch.rb, line 11
def launch_children(parent, input_hash)
  input_hash.map do |task_id, input|
    launcher = child_launcher(parent)
    triggered = launcher.launch!(transform_input(input), id: task_id)
    results[task_id] = launcher.results
    triggered
  end
end
prepare_batch(input_hash) click to toggle source
# File lib/smart_proxy_dynflow/task_launcher/batch.rb, line 20
def prepare_batch(input_hash)
  input_hash
end

Private Instance Methods

action_class() click to toggle source
# File lib/smart_proxy_dynflow/task_launcher/batch.rb, line 35
def action_class
  Proxy::Dynflow::Action::Batch
end
transform_input(input) click to toggle source

Identity by default

# File lib/smart_proxy_dynflow/task_launcher/batch.rb, line 31
def transform_input(input)
  input
end