v0.42.1 Rewrite and simplication of concurrent-ruby support

This commit is contained in:
David Sainty 2024-08-17 23:57:56 +10:00
parent 8e6edb2d3f
commit b7fcb220c9

View File

@ -1162,7 +1162,9 @@ class GossamerForumsImporter < ImportScripts::Base
#### break if current_post_batch >= parent_post_count #### break if current_post_batch >= parent_post_count
# Wait for all jobs in the current batch to finish before proceeding # Wait for all jobs in the current batch to finish before proceeding
puts "PP 33 -- Ready for shutdown"
pool.shutdown # Initiate thread pool shutdown after all jobs submitted pool.shutdown # Initiate thread pool shutdown after all jobs submitted
puts "PP 44 -- Now wait for termination"
pool.wait_for_termination # Wait for all threads to finish exec pool.wait_for_termination # Wait for all threads to finish exec
# Check if all posts have been processed # Check if all posts have been processed