diff options
Diffstat (limited to 'app/workers/delete_container_repository_worker.rb')
-rw-r--r-- | app/workers/delete_container_repository_worker.rb | 61 |
1 files changed, 1 insertions, 60 deletions
diff --git a/app/workers/delete_container_repository_worker.rb b/app/workers/delete_container_repository_worker.rb index 73e6843fdd0..d0552dce9fc 100644 --- a/app/workers/delete_container_repository_worker.rb +++ b/app/workers/delete_container_repository_worker.rb @@ -11,64 +11,5 @@ class DeleteContainerRepositoryWorker # rubocop:disable Scalability/IdempotentWo queue_namespace :container_repository feature_category :container_registry - LEASE_TIMEOUT = 1.hour.freeze - FIXED_DELAY = 10.seconds.freeze - - attr_reader :container_repository - - def perform(current_user_id, container_repository_id) - current_user = User.find_by_id(current_user_id) - @container_repository = ContainerRepository.find_by_id(container_repository_id) - project = container_repository&.project - - return unless current_user && container_repository && project - - if migration.delete_container_repository_worker_support? && migrating? - delay = migration_duration - - self.class.perform_in(delay.from_now) - - log_extra_metadata_on_done(:delete_postponed, delay) - - return - end - - # If a user accidentally attempts to delete the same container registry in quick succession, - # this can lead to orphaned tags. - try_obtain_lease do - Projects::ContainerRepository::DestroyService.new(project, current_user).execute(container_repository) - end - end - - private - - def migrating? - !(container_repository.default? || - container_repository.import_done? || - container_repository.import_skipped?) - end - - def migration_duration - duration = migration.import_timeout.seconds + FIXED_DELAY - - if container_repository.pre_importing? - duration += migration.dynamic_pre_import_timeout_for(container_repository) - end - - duration - end - - def migration - ContainerRegistry::Migration - end - - # For ExclusiveLeaseGuard concern - def lease_key - @lease_key ||= "container_repository:delete:#{container_repository.id}" - end - - # For ExclusiveLeaseGuard concern - def lease_timeout - LEASE_TIMEOUT - end + def perform(current_user_id, container_repository_id); end end |