Sha256: 1041e4ea115d51fae66777f12ccbfe898f08ab4ee64fd717f0c2140d0cce9a19

Contents?: true

Size: 793 Bytes

Versions: 4

Compression:

Stored size: 793 Bytes

Contents

require 'sneakers'
require 'sneakers/runner'

task :environment

namespace :sneakers do
  desc "Start work (set $WORKERS=Klass1,Klass2)"
  task :run  => :environment do

    workers, missing_workers = Sneakers::Utils.parse_workers(ENV['WORKERS'])

    unless missing_workers.empty?
      puts "Missing workers: #{missing_workers.join(', ')}" if missing_workers
      puts "Did you `require` properly?"
      exit(1)
    end

    if workers.empty?
      puts <<EOF
Error: No workers found.
Please set the classes of the workers you want to run like so:

  $ export WORKERS=MyWorker,FooWorker
  $ rake sneakers:run

EOF
      exit(1)
    end
    opts = (ENV['WORKER_COUNT'].present? ? {:workers => ENV['WORKER_COUNT'].to_i} : {})
    r = Sneakers::Runner.new(workers, opts)

    r.run
  end
end

Version data entries

4 entries across 4 versions & 2 rubygems

Version Path
sneakers_custom_bunny-1.0.4 lib/sneakers/tasks.rb
sneakers-1.0.4 lib/sneakers/tasks.rb
sneakers-1.0.3 lib/sneakers/tasks.rb
sneakers-1.0.2 lib/sneakers/tasks.rb