lib/umbrellio_utils/jobs.rb in umbrellio-utils-1.5.0 vs lib/umbrellio_utils/jobs.rb in umbrellio-utils-1.5.1

- old
+ new

@@ -65,10 +65,11 @@ result = capsules.filter_map do |capsule| weight_coef = capsule.weight / total_weight.to_f concurrency = (max_concurrency * weight_coef).to_i concurrency = 1 unless concurrency > 1 - queues = self.queues.select { |x| x.capsule == capsule.name }.map { |x| [x.name, x.weight] } + queues = + self.queues.select { |x| x.capsule == capsule.name }.map { |x| [x.name.to_s, x.weight] } Entry.new(capsule.name, queues, concurrency) end raise "No queues found for worker #{worker.inspect}" if result.empty?