From 5ebe94cf3703daa29fc0e8229f8d1013834f4407 Mon Sep 17 00:00:00 2001 From: Lionel Pereira Date: Fri, 1 Dec 2023 17:36:53 -0500 Subject: [PATCH] CCOL-2039: Variable rename --- lib/deimos/active_record_consume/batch_consumption.rb | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/lib/deimos/active_record_consume/batch_consumption.rb b/lib/deimos/active_record_consume/batch_consumption.rb index 2016b8bb..b2d9341a 100644 --- a/lib/deimos/active_record_consume/batch_consumption.rb +++ b/lib/deimos/active_record_consume/batch_consumption.rb @@ -179,9 +179,9 @@ def filter_records(record_list) record_list.filter!(self.method(:should_consume?).to_proc, consume_filter) end - # @return [NilClass,ActiveRecord::Relation,Hash,Set] + # @return [ActiveRecord::Relation,Hash,Set] def consume_filter - nil + { } end # @param messages [Array] @@ -210,10 +210,10 @@ def build_records(messages) end # Additional processing after records have been successfully upserted - # @param _valid_records [Array] Records to be post processed - # @param _invalid_records [Array] Invalid records to be processed + # @param _valid_active_records [Array] Records to be post processed + # @param _invalid_batch_records [Array] Invalid records to be processed # @return [void] - def post_process(_valid_records, _invalid_records) + def post_process(_valid_active_records, _invalid_batch_records) nil end