28 lines
732 B
Ruby
28 lines
732 B
Ruby
# frozen_string_literal: true
|
|
|
|
module Ci
|
|
class AfterRequeueJobService < ::BaseService
|
|
def execute(processable)
|
|
process_subsequent_jobs(processable)
|
|
reset_source_bridge(processable)
|
|
end
|
|
|
|
private
|
|
|
|
def process_subsequent_jobs(processable)
|
|
processable.pipeline.processables.skipped.after_stage(processable.stage_idx).find_each do |processable|
|
|
process(processable)
|
|
end
|
|
end
|
|
|
|
def reset_source_bridge(processable)
|
|
processable.pipeline.reset_source_bridge!(current_user)
|
|
end
|
|
|
|
def process(processable)
|
|
Gitlab::OptimisticLocking.retry_lock(processable, name: 'ci_requeue_job') do |processable|
|
|
processable.process(current_user)
|
|
end
|
|
end
|
|
end
|
|
end
|