diff --git a/app/models/project_pages_metadatum.rb b/app/models/project_pages_metadatum.rb index 347c06db4e63622d25fc0dec5a0cc410bc3ccd2b..0b12367f4bf2c24330c9ee54dbe2809c603c48c6 100644 --- a/app/models/project_pages_metadatum.rb +++ b/app/models/project_pages_metadatum.rb @@ -11,5 +11,5 @@ class ProjectPagesMetadatum < ApplicationRecord scope :deployed, -> { where(deployed: true) } scope :only_on_legacy_storage, -> { deployed.where(pages_deployment: nil) } - scope :with_project_route_and_deployment, -> { preload(project: [:namespace, :route, pages_metadatum: :pages_deployment]) } + scope :with_project_route_and_deployment, -> { preload(:pages_deployment, project: [:namespace, :route]) } end 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