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?