lib/thinking_sphinx/deltas/delete_job.rb in thinking-sphinx-3.0.4 vs lib/thinking_sphinx/deltas/delete_job.rb in thinking-sphinx-3.0.5
- old
+ new
@@ -2,10 +2,10 @@
def initialize(index_name, document_id)
@index_name, @document_id = index_name, document_id
end
def perform
- ThinkingSphinx::Connection.pool.take do |connection|
+ ThinkingSphinx::Connection.take do |connection|
connection.execute Riddle::Query.update(
@index_name, @document_id, :sphinx_deleted => true
)
end
rescue Mysql2::Error => error