Class: Sidekiq::Recursive::Start

Inherits:
Object
  • Object
show all
Defined in:
lib/sidekiq/recursive/start.rb

Class Method Summary collapse

Class Method Details

.run(worker, arguments) ⇒ Object 



2
3
4
5
6
7
8
9
10
11
12
 
# 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