lib/mini_scheduler.rb in mini_scheduler-0.11.0 vs lib/mini_scheduler.rb in mini_scheduler-0.12.0
- old
+ new
@@ -50,14 +50,14 @@
def self.skip_schedule(&blk)
@skip_schedule = blk if blk
@skip_schedule
end
- def self.start
+ def self.start(workers: 1)
schedules = Manager.discover_schedules
Manager.discover_queues.each do |queue|
- manager = Manager.new(queue: queue)
+ manager = Manager.new(queue: queue, workers: workers)
schedules.each do |schedule|
if schedule.queue == queue
manager.ensure_schedule!(schedule)
end