Added sleep_delay and read_ahead to options for rake tasks.

collectiveidea · Jun 18, 2014 · 110f0e2 · 110f0e2
1 parent 5b08ccd
commit 110f0e2
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/lib/delayed/tasks.rb b/lib/delayed/tasks.rb
@@ -21,6 +21,9 @@
       :queues => (ENV['QUEUES'] || ENV['QUEUE'] || '').split(','),
       :quiet => false
     }
+
+    @worker_options[:sleep_delay] = ENV['SLEEP_DELAY'].to_i if ENV['SLEEP_DELAY']
+    @worker_options[:read_ahead] = ENV['READ_AHEAD'].to_i if ENV['READ_AHEAD']
   end
 
   desc "Exit with error status if any jobs older than max_age seconds haven't been attempted yet."