From 872069493171084e0e4b280a2806c313e9c5f657 Mon Sep 17 00:00:00 2001 From: Trey Pendragon Date: Thu, 12 Oct 2023 14:41:14 -0700 Subject: [PATCH] Include barrier. --- app/services/card_image_loading_service.rb | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/app/services/card_image_loading_service.rb b/app/services/card_image_loading_service.rb index 24d75ee..cf1c267 100644 --- a/app/services/card_image_loading_service.rb +++ b/app/services/card_image_loading_service.rb @@ -26,16 +26,16 @@ def import end end.flat_map(&:wait) progress_bar.total = all_files.count - import_files(all_files) + import_files(all_files, barrier) ensure barrier.stop end end - def import_files(all_files) + def import_files(all_files, barrier) Sync do # Insert 10 batches at a time. - semaphore = Async::Semaphore.new(10) + semaphore = Async::Semaphore.new(10, parent: barrier) # insert_all in batches of 1000 all_files.each_slice(1000).map do |slice| semaphore.async do