Skip to content

Commit dd82aca

Browse files
Fix unknown attribute reference error
1 parent d8b852e commit dd82aca

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

lib/job-iteration/active_record_batch_enumerator.rb

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@ def initialize(relation, columns: nil, batch_size: 100, cursor: nil)
2929
raise JobIteration::ActiveRecordCursor::ConditionNotSupportedError
3030
end
3131

32-
@base_relation = relation.reorder(@columns.join(","))
32+
@base_relation = relation.reorder(Arel.sql(@columns.join(",")))
3333
end
3434

3535
def each

lib/job-iteration/active_record_cursor.rb

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@ def initialize(relation, columns, position = nil)
3030
raise ConditionNotSupportedError
3131
end
3232

33-
@base_relation = relation.reorder(*@columns)
33+
@base_relation = relation.reorder(Arel.sql(@columns.join(",")))
3434
@reached_end = false
3535
end
3636

0 commit comments

Comments
 (0)