Use set_notice_processor

ankane · Apr 17, 2023 · 8535a7c · 8535a7c
1 parent bf32bb5
commit 8535a7c
Showing 1 changed file with 7 additions and 4 deletions.
diff --git a/lib/dexter/indexer.rb b/lib/dexter/indexer.rb
@@ -669,16 +669,19 @@ def with_advisory_lock
  end
  yield
  ensure
- with_min_messages("error") do
+ suppress_messages do
  execute("SELECT pg_advisory_unlock($1)", params: [lock_id])
  end
  end
 
- def with_min_messages(value)
- execute("SET client_min_messages = #{quote(value)}")
+ def suppress_messages
+ conn.set_notice_processor do |message|
+ # do nothing
+ end
  yield
  ensure
- execute("SET client_min_messages = warning")
+ # clear notice processor
+ conn.set_notice_processor
  end
 
  def index_exists?(index)