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 }