1 files changed, 11 insertions, 7 deletions
diff --git a/app/workers/ci/ref_delete_unlock_artifacts_worker.rb b/app/workers/ci/ref_delete_unlock_artifacts_worker.rb
index aeadf111bfb..e343c0aedd4 100644
--- a/app/workers/ci/ref_delete_unlock_artifacts_worker.rb
+++ b/app/workers/ci/ref_delete_unlock_artifacts_worker.rb
@@ -13,17 +13,21 @@ module Ci
 
     def perform(project_id, user_id, ref_path)
       ::Project.find_by_id(project_id).try do |project|
-        ::User.find_by_id(user_id).try do |user|
+        ::User.find_by_id(user_id).try do |_|
           project.ci_refs.find_by_ref_path(ref_path).try do |ci_ref|
-            results = ::Ci::UnlockArtifactsService
-              .new(project, user)
-              .execute(ci_ref)
-
-            log_extra_metadata_on_done(:unlocked_pipelines, results[:unlocked_pipelines])
-            log_extra_metadata_on_done(:unlocked_job_artifacts, results[:unlocked_job_artifacts])
+            enqueue_pipelines_to_unlock(ci_ref)
           end
         end
       end
     end
+
+    private
+
+    def enqueue_pipelines_to_unlock(ci_ref)
+      result = ::Ci::Refs::EnqueuePipelinesToUnlockService.new.execute(ci_ref)
+
+      log_extra_metadata_on_done(:total_pending_entries, result[:total_pending_entries])
+      log_extra_metadata_on_done(:total_new_entries, result[:total_new_entries])
+    end
   end
 end