class Baleen::RunnerManager

Public Class Methods

new(connection, task) click to toggle source
# File lib/baleen/runner.rb, line 7
def initialize(connection, task)
  @task       = task
  @connection = connection
end

Public Instance Methods

run() { |task| ... } click to toggle source
# File lib/baleen/runner.rb, line 12
def run
  results = []
  prepare_task
  create_runners.each do |runners|
    runners.map{|runner| runner.future.run}.each do |actor|
      results << actor.value
    end
  end
  @task.results = results
  yield @task
end

Private Instance Methods

create_runners() click to toggle source
# File lib/baleen/runner.rb, line 30
def create_runners
  @task.target_files.map {|file|
    task = @task.dup
    task.files = file
    Runner.new(task, @connection)
  }.each_slice(@task.concurrency).map {|r| r}
end
prepare_task() click to toggle source
# File lib/baleen/runner.rb, line 26
def prepare_task
  @task.prepare
end