diff --git a/lib/deimos/active_record_consume/batch_consumption.rb b/lib/deimos/active_record_consume/batch_consumption.rb index 676dc04b..7929704b 100644 --- a/lib/deimos/active_record_consume/batch_consumption.rb +++ b/lib/deimos/active_record_consume/batch_consumption.rb @@ -121,8 +121,7 @@ def compact_messages(batch) def uncompacted_update(messages) valid_records = [] invalid_records = [] - BatchSlicer. - slice(messages).each do |slice| + BatchSlicer.slice(messages).each do |slice| valid, invalid = update_database(slice) valid_records.push(*valid) if valid.any? invalid_records.push(*invalid) if invalid.any?