v0.42.1 Rewrite and simplication of concurrent-ruby support

This commit is contained in:
David Sainty 2024-08-18 01:08:13 +10:00
parent 7847784e0e
commit 5c648f97c1

View File

@ -1132,7 +1132,7 @@ class GossamerForumsImporter < ImportScripts::Base
)
puts "PP 22 -- #{post_id}"
## begin
begin
# Use connection pooling for PostgreSQL and synchronize access to shared resources
ActiveRecord::Base.connection_pool.with_connection do
post_status = post_status(post_id)
@ -1146,15 +1146,15 @@ class GossamerForumsImporter < ImportScripts::Base
puts "Skipping post_id #{post_id}, already processed."
end
end
## rescue => e
rescue => e
puts "Error processing post ID #{post_id}: #{e.message}"
sqlite_mutex.synchronize do
mark_post_as_failed(post_id)
end
## ensure
ensure
# Ensure the MariaDB connection is closed after processing
mysql_client.close if mysql_client
## end
end
end
end