gitlab-org--gitlab-foss/app/workers/update_head_pipeline_for_me...

# frozen_string_literal: true

class UpdateHeadPipelineForMergeRequestWorker
  include ApplicationWorker
  include PipelineQueue

  queue_namespace :pipeline_processing

  def perform(merge_request_id)
    merge_request = MergeRequest.find(merge_request_id)

    sha = merge_request.diff_head_sha
    pipeline = merge_request.all_pipelines(shas: sha).first

    return unless pipeline && pipeline.latest?

    if merge_request.diff_head_sha != pipeline.sha
      log_error_message_for(merge_request)

      return
    end

    merge_request.update_attribute(:head_pipeline_id, pipeline.id)
  end

  def log_error_message_for(merge_request)
    Rails.logger.error(
      "Outdated head pipeline for active merge request: id=#{merge_request.id}, source_branch=#{merge_request.source_branch}, diff_head_sha=#{merge_request.diff_head_sha}"
    )
  end
end
Enable frozen string literals for app/workers/*.rb 2018-06-27 07:23:28 +00:00			`# frozen_string_literal: true`

Ensure pippeline corresponds with the sha of an MR 2017-09-07 07:58:15 +00:00			`class UpdateHeadPipelineForMergeRequestWorker`
Fix update head pipeline worker 2017-12-05 17:14:37 +00:00			`include ApplicationWorker`
Use a dedicated queue for each worker 2017-11-28 16:16:50 +00:00			`include PipelineQueue`
Ensure pippeline corresponds with the sha of an MR 2017-09-07 07:58:15 +00:00
Change queue namespace of UpdateHeadPipelineForMergeRequestWorker 2018-03-06 17:43:10 +00:00			`queue_namespace :pipeline_processing`

Ensure pippeline corresponds with the sha of an MR 2017-09-07 07:58:15 +00:00			`def perform(merge_request_id)`
			`merge_request = MergeRequest.find(merge_request_id)`
Merge request pipelines 2018-12-05 06:57:00 +00:00
			`sha = merge_request.diff_head_sha`
			`pipeline = merge_request.all_pipelines(shas: sha).first`
Ensure pippeline corresponds with the sha of an MR 2017-09-07 07:58:15 +00:00
			`return unless pipeline && pipeline.latest?`
Prevent worker that updates merge requests head pipeline from failing jobs 2017-12-11 21:00:11 +00:00
			`if merge_request.diff_head_sha != pipeline.sha`
			`log_error_message_for(merge_request)`

			`return`
			`end`
Ensure pippeline corresponds with the sha of an MR 2017-09-07 07:58:15 +00:00
			`merge_request.update_attribute(:head_pipeline_id, pipeline.id)`
			`end`
Prevent worker that updates merge requests head pipeline from failing jobs 2017-12-11 21:00:11 +00:00
			`def log_error_message_for(merge_request)`
			`Rails.logger.error(`
			`"Outdated head pipeline for active merge request: id=#{merge_request.id}, source_branch=#{merge_request.source_branch}, diff_head_sha=#{merge_request.diff_head_sha}"`
			`)`
			`end`
Ensure pippeline corresponds with the sha of an MR 2017-09-07 07:58:15 +00:00			`end`