diff --git a/app/services/pages/migrate_from_legacy_storage_service.rb b/app/services/pages/migrate_from_legacy_storage_service.rb
index e6c9240df5280e290189a6b194d542141124db04..c7a996a557f562cb77b001c15772b781ef484448 100644
--- a/app/services/pages/migrate_from_legacy_storage_service.rb
+++ b/app/services/pages/migrate_from_legacy_storage_service.rb
@@ -32,8 +32,10 @@ def execute
     def start_migration_threads
       Array.new(@migration_threads) do
         Thread.new do
-          while batch = @queue.pop
-            process_batch(batch)
+          Rails.application.executor.wrap do
+            while batch = @queue.pop
+              process_batch(batch)
+            end
           end
         end
       end