Merge remote-tracking branch 'origin/pr/669'

collectiveidea · Sep 24, 2014 · 56e8e71 · 56e8e71
2 parents bb3d3a8 + 110f0e2
commit 56e8e71
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."