Contents

require "sneakers/runner"

task :environment

namespace :sneakers do
  desc "Start processing jobs with all workers"
  task work: :environment do
    silence_warnings do
      Rails.application.eager_load! unless Rails.application.config.eager_load
    end

    workers = ApplicationJob.subclasses.map do |klass|
      klass.const_set("Wrapper", Class.new(ActiveJob::QueueAdapters::SneakersAdapter::JobWrapper) do
        from_queue klass.queue_name
      end)
    end


    Sneakers::Runner.new(workers).run
  end
end

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
sapience-1.0.11	test_apps/rails/lib/tasks/sneakers.rake
sapience-1.0.10	test_apps/rails/lib/tasks/sneakers.rake
sapience-1.0.9	test_apps/rails/lib/tasks/sneakers.rake
sapience-1.0.8	test_apps/rails/lib/tasks/sneakers.rake
sapience-1.0.7	test_apps/rails/lib/tasks/sneakers.rake
sapience-1.0.6	test_apps/rails/lib/tasks/sneakers.rake
sapience-1.0.5	test_apps/rails/lib/tasks/sneakers.rake
sapience-1.0.4	test_apps/rails/lib/tasks/sneakers.rake