Fix migration threads for pages migration

ca0c3d76 · Vladimir Shushlin · f69c6a72 · ca0c3d76
Commit ca0c3d76 authored Jan 26, 2021 by Vladimir Shushlin
Hide whitespace changes
Inline Side-by-side

Showing with 4 additions and 2 deletions

app/services/pages/migrate_from_legacy_storage_service.rb app/services/pages/migrate_from_legacy_storage_service.rb +4 -2

No files found.
--- a/app/services/pages/migrate_from_legacy_storage_service.rb
+++ b/app/services/pages/migrate_from_legacy_storage_service.rb
@@ -32,8 +32,10 @@ module Pages
    def start_migration_threads
      Array.new(@migration_threads) do
        Thread.new do
-          while batch = @queue.pop
+          Rails.application.executor.wrap do
-            process_batch(batch)
+            while batch = @queue.pop
+              process_batch(batch)
+            end
          end
        end
      end