diff options
Diffstat (limited to 'app/workers/hashed_storage')
4 files changed, 4 insertions, 32 deletions
diff --git a/app/workers/hashed_storage/migrator_worker.rb b/app/workers/hashed_storage/migrator_worker.rb index 5f90b8f1009..a7e7a505681 100644 --- a/app/workers/hashed_storage/migrator_worker.rb +++ b/app/workers/hashed_storage/migrator_worker.rb @@ -13,9 +13,6 @@ module HashedStorage # @param [Integer] start initial ID of the batch # @param [Integer] finish last ID of the batch - def perform(start, finish) - migrator = Gitlab::HashedStorage::Migrator.new - migrator.bulk_migrate(start: start, finish: finish) - end + def perform(start, finish); end end end diff --git a/app/workers/hashed_storage/project_migrate_worker.rb b/app/workers/hashed_storage/project_migrate_worker.rb index 01e2d6307de..e1bf71de179 100644 --- a/app/workers/hashed_storage/project_migrate_worker.rb +++ b/app/workers/hashed_storage/project_migrate_worker.rb @@ -13,17 +13,6 @@ module HashedStorage attr_reader :project_id - def perform(project_id, old_disk_path = nil) - @project_id = project_id # we need to set this in order to create the lease_key - - try_obtain_lease do - project = Project.without_deleted.find_by_id(project_id) - break unless project && project.storage_upgradable? - - old_disk_path ||= Storage::LegacyProject.new(project).disk_path - - ::Projects::HashedStorage::MigrationService.new(project, old_disk_path, logger: logger).execute - end - end + def perform(project_id, old_disk_path = nil); end end end diff --git a/app/workers/hashed_storage/project_rollback_worker.rb b/app/workers/hashed_storage/project_rollback_worker.rb index 2ec323248ab..af4223ff354 100644 --- a/app/workers/hashed_storage/project_rollback_worker.rb +++ b/app/workers/hashed_storage/project_rollback_worker.rb @@ -13,17 +13,6 @@ module HashedStorage attr_reader :project_id - def perform(project_id, old_disk_path = nil) - @project_id = project_id # we need to set this in order to create the lease_key - - try_obtain_lease do - project = Project.without_deleted.find_by_id(project_id) - break unless project - - old_disk_path ||= project.disk_path - - ::Projects::HashedStorage::RollbackService.new(project, old_disk_path, logger: logger).execute - end - end + def perform(project_id, old_disk_path = nil); end end end diff --git a/app/workers/hashed_storage/rollbacker_worker.rb b/app/workers/hashed_storage/rollbacker_worker.rb index c6c4990d799..e659e65a370 100644 --- a/app/workers/hashed_storage/rollbacker_worker.rb +++ b/app/workers/hashed_storage/rollbacker_worker.rb @@ -13,9 +13,6 @@ module HashedStorage # @param [Integer] start initial ID of the batch # @param [Integer] finish last ID of the batch - def perform(start, finish) - migrator = Gitlab::HashedStorage::Migrator.new - migrator.bulk_rollback(start: start, finish: finish) - end + def perform(start, finish); end end end |