add to cli config

Author: onyxraven

lib/resque/scheduler/cli.rb

@@ -16,7 +16,9 @@ module Scheduler
       pidfile: 'PIDFILE',
       poll_sleep_amount: 'RESQUE_SCHEDULER_INTERVAL',
       verbose: 'VERBOSE',
-      lock_timeout: 'LOCK_TIMEOUT'
+      lock_timeout: 'LOCK_TIMEOUT',
+      delayed_requeue_batch_size: 'DELAYED_REQUEUE_BATCH_SIZE',
+      disable_delayed_requeue_batches: 'DISABLE_DELAYED_REQUEUE_BATCHES'
     }.freeze
 
     class Cli
@@ -74,6 +76,18 @@ class Cli
         {
           args: ['-v', '--verbose', 'Run with verbose output [VERBOSE]'],
           callback: ->(options) { ->(v) { options[:verbose] = v } }
+        },
+        {
+          args: ['--lock-timeout [LOCK_TIMEOUT]', 'Lock timeout'],
+          callback: ->(options) { ->(t) { options[:lock_timeout] = t } }
+        },
+        {
+          args: ['--delayed-requeue-batch-size [DELAYED_REQUEUE_BATCH_SIZE]', 'Delayed requeue batch size'],
+          callback: ->(options) { ->(d) { options[:delayed_requeue_batch_size] = d } }
+        },
+        {
+          args: ['--disable-delayed-requeue-batches [DISABLE_DELAYED_REQUEUE_BATCHES]', 'Disable delayed requeue batches'],
+          callback: ->(options) { ->(d) { options[:disable_delayed_requeue_batches] = d } }
         }
       ].freeze
 

lib/resque/scheduler/env.rb

@@ -67,13 +67,17 @@ def setup_scheduler_configuration
 
           c.logformat = options[:logformat] if options.key?(:logformat)
 
-          c.lock_timeout = options[:lock_timeout] if options.key?(:lock_timeout)
+          c.lock_timeout = options[:lock_timeout].to_i if options.key?(:lock_timeout)
 
           if (psleep = options[:poll_sleep_amount]) && !psleep.nil?
             c.poll_sleep_amount = Float(psleep)
           end
 
           c.verbose = !!options[:verbose] if options.key?(:verbose)
+
+          c.delayed_requeue_batch_size = options[:delayed_requeue_batch_size].to_i if options.key?(:delayed_requeue_batch_size)
+
+          c.disable_delayed_requeue_batches = !!options[:disable_delayed_requeue_batches] if options.key?(:disable_delayed_requeue_batches)
         end
       end
       # rubocop:enable Metrics/AbcSize