Method: Rockflow::Flow#execute_steps

Defined in:
lib/rockflow/flow.rb

#execute_steps ⇒ Object 



42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
 
# File 'lib/rockflow/flow.rb', line 42

def execute_steps
  while !steps_finished?
    ::Parallel.each(next_free_steps, threads_or_processes.to_sym => Rockflow.configuration.thread_or_processes) do |step|
      begin
        step.execute_pre_conditions
        step.it_up unless step.failed?
        step.execute_post_conditions
        step.finish! unless step.failed?
      rescue e
        raise Parallel::Break, e.message
      end
    end
  end
  @steps
end