diff --git a/lib/job-iteration/active_record_batch_enumerator.rb b/lib/job-iteration/active_record_batch_enumerator.rb index 743f6fff..77a45c12 100644 --- a/lib/job-iteration/active_record_batch_enumerator.rb +++ b/lib/job-iteration/active_record_batch_enumerator.rb @@ -34,7 +34,6 @@ def initialize(relation, columns: nil, batch_size: 100, cursor: nil) def each return to_enum { size } unless block_given? while (relation = next_batch) - break if @cursor.nil? yield relation, cursor_value end end