Method: ConflowSpec::Runner#run

Defined in:
lib/conflow_spec/runner.rb

#run ⇒ Object

Performs all jobs in the flow, saving results in #performed_jobs



18
19
20
21
22
23
24
25
26
27
 
# File 'lib/conflow_spec/runner.rb', line 18

def run
  until queue.empty?
    job = queue.pop

    perform(flow.id, job.id) do |worker_type, params|
      performed_jobs << [worker_type, params.to_h]
      fetch_result(job)
    end
  end
end