diff --git a/lib/deimos/utils/db_poller.rb b/lib/deimos/utils/db_poller.rb index 449a9359..ffb94727 100644 --- a/lib/deimos/utils/db_poller.rb +++ b/lib/deimos/utils/db_poller.rb @@ -131,8 +131,8 @@ def fetch_results(time_from, time_to) time_to: time_to, column_name: @config.timestamp_column, min_id: @info.last_sent_id). - limit(BATCH_SIZE). - order("#{@producer.config[:record_class].table_name}.#{quoted_timestamp}, #{quoted_id}") + limit(BATCH_SIZE). + order("#{@producer.config[:record_class].table_name}.#{quoted_timestamp}, #{quoted_id}") end # @param batch [Array]