lib/relaton/db.rb in relaton-1.9.5 vs lib/relaton/db.rb in relaton-1.9.6
- old
+ new
@@ -103,10 +103,11 @@
def fetch_async(code, year = nil, opts = {}, &block) # rubocop:disable Metrics/AbcSize,Metrics/MethodLength
stdclass = standard_class code
if stdclass
unless @queues[stdclass]
processor = @registry.processors[stdclass]
- wp = WorkersPool.new(processor.threads) do |args|
+ threads = ENV["RELATON_FETCH_PARALLEL"]&.to_i || processor.threads
+ wp = WorkersPool.new(threads) do |args|
args[3].call fetch(*args[0..2])
rescue RelatonBib::RequestError => e
args[3].call e
end
@queues[stdclass] = { queue: Queue.new, workers_pool: wp }