1 parent 7e7b926 commit 7e96d48Copy full SHA for 7e96d48
1 file changed
lib/sneakers/worker.rb
@@ -19,7 +19,7 @@ def initialize(queue = nil, pool = nil, opts = {})
19
20
@should_ack = opts[:ack]
21
@timeout_after = opts[:timeout_job_after]
22
- @pool = pool || Concurrent::FixedThreadPool.new(opts[:threads])
+ @pool = pool || Concurrent::FixedThreadPool.new(opts[:threads] || Sneakers::Configuration::DEFAULTS[:threads])
23
@call_with_params = respond_to?(:work_with_params)
24
@content_type = opts[:content_type]
25
0 commit comments