lib/distribute_reads.rb in distribute_reads-0.3.4 vs lib/distribute_reads.rb in distribute_reads-0.3.5
- old
+ new
@@ -45,10 +45,10 @@
# cache the version number
@aurora_postgres ||= {}
cache_key = connection.pool.object_id
unless @aurora_postgres.key?(cache_key)
- @aurora_postgres[cache_key] = connection.select_all("SELECT 1 FROM pg_stat_activity WHERE backend_type = 'aurora runtime'").any?
+ @aurora_postgres[cache_key] = connection.select_all("SELECT 1 FROM pg_stat_activity WHERE backend_type IN ('aurora runtime', 'aurora runtime process')").any?
end
@server_version_num ||= {}
@server_version_num[cache_key] ||= connection.select_all("SHOW server_version_num").first["server_version_num"].to_i