v0.42.1 Rewrite and simplication of concurrent-ruby support
This commit is contained in:
parent
ef50d344c9
commit
5a0e8a7d2b
@ -1129,9 +1129,9 @@ class GossamerForumsImporter < ImportScripts::Base
|
||||
password: "yxnh93Ybbz2Nm8#mp28zCVv",
|
||||
database: "slowtwitch"
|
||||
)
|
||||
puts "PP 22 -- ${post_id}"
|
||||
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)
|
||||
@ -1145,15 +1145,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
|
||||
|
||||
|
Loading…
Reference in New Issue
Block a user