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