diff --git a/app/jobs/data_warehouse/table_summary_stats_export_job.rb b/app/jobs/data_warehouse/table_summary_stats_export_job.rb index 3f74bb85198..7fef9cabee5 100644 --- a/app/jobs/data_warehouse/table_summary_stats_export_job.rb +++ b/app/jobs/data_warehouse/table_summary_stats_export_job.rb @@ -29,7 +29,9 @@ def max_ids_and_counts(timestamp) end def table_has_id_column?(table) - ActiveRecord::Base.connection.columns(table).map(&:name).include?('id') + ActiveRecord::Base.connection.columns(table).any? do |column| + column.name == 'id' && column.type == :integer + end end def fetch_max_id_and_count(table, timestamp)