class Proxy::Dynflow::TaskLauncher::AbstractGroup
Public Class Methods
runner_class()
click to toggle source
# File lib/smart_proxy_dynflow/task_launcher/group.rb, line 6 def self.runner_class raise NotImplementedError end
Public Instance Methods
action_class()
click to toggle source
# File lib/smart_proxy_dynflow/task_launcher/group.rb, line 10 def action_class Action::SingleRunnerBatch end
launch_children(parent, input_hash)
click to toggle source
Calls superclass method
Proxy::Dynflow::TaskLauncher::Batch#launch_children
# File lib/smart_proxy_dynflow/task_launcher/group.rb, line 14 def launch_children(parent, input_hash) super(parent, input_hash) trigger(parent, Action::BatchRunner, self, input_hash) end
operation()
click to toggle source
# File lib/smart_proxy_dynflow/task_launcher/group.rb, line 19 def operation raise NotImplementedError end
runner_input(input)
click to toggle source
# File lib/smart_proxy_dynflow/task_launcher/group.rb, line 23 def runner_input(input) input.reduce({}) do |acc, (id, input)| input = { :execution_plan_id => results[id][:task_id], :run_step_id => 2, :input => input } acc.merge(id => input) end end
Private Instance Methods
child_launcher(parent)
click to toggle source
# File lib/smart_proxy_dynflow/task_launcher/group.rb, line 34 def child_launcher(parent) Single.new(world, callback, :parent => parent, :action_class_override => Action::OutputCollector) end
transform_input(input)
click to toggle source
# File lib/smart_proxy_dynflow/task_launcher/group.rb, line 38 def transform_input(input) wipe_callback(input) end
wipe_callback(input)
click to toggle source
# File lib/smart_proxy_dynflow/task_launcher/group.rb, line 42 def wipe_callback(input) callback = input['action_input']['callback'] input.merge('action_input' => input['action_input'].merge('callback' => nil, :task_id => callback['task_id'])) end