class Sidekiq::Recursive::Start
Public Class Methods
run(worker, arguments)
click to toggle source
# File lib/sidekiq/recursive/start.rb, line 2 def self.run(worker, arguments) Sidekiq::Recursive::ArgumentQueue.push(worker, arguments) Sidekiq::Recursive::Hooks::BeforeAll.run(worker) 1.upto(worker.recursive_worker_count) do |worker_id| argument = Sidekiq::Recursive::ArgumentQueue.pop(worker) worker.perform_async(worker_id, argument) end true end