diff --git a/lib/que/adapters/active_record_with_lock.rb b/lib/que/adapters/active_record_with_lock.rb index f23ad21..cdcb717 100644 --- a/lib/que/adapters/active_record_with_lock.rb +++ b/lib/que/adapters/active_record_with_lock.rb @@ -26,6 +26,9 @@ def initialize(job_connection_pool:, lock_connection_pool:) def checkout_activerecord_adapter(&block) checkout_lock_database_connection do @job_connection_pool.with_connection(&block) + # rescue ::PG::Error, ::ActiveRecord::StatementInvalid => e + # remove_dead_connections(e) + # raise end end