2 3 4 5 6 7 8
# File 'lib/sidekiq/grouping/flusher.rb', line 2 def flush batches = Sidekiq::Grouping::Batch.all.map do |batch| batch if batch.could_flush? end batches.compact! flush_concrete(batches) end