blob: fbd62ac0a91ff77febf0538c2844ec3c826dd5e8 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
|
# frozen_string_literal: true
class MergeRequestCleanupRefsWorker
include ApplicationWorker
feature_category :code_review
idempotent!
def perform(merge_request_id)
return unless Feature.enabled?(:merge_request_refs_cleanup, default_enabled: false)
merge_request = MergeRequest.find_by_id(merge_request_id)
unless merge_request
logger.error("Failed to find merge request with ID: #{merge_request_id}")
return
end
result = ::MergeRequests::CleanupRefsService.new(merge_request).execute
return if result[:status] == :success
logger.error("Failed cleanup refs of merge request (#{merge_request_id}): #{result[:message]}")
end
end
|