app/workers/ci/merge_requests/add_todo_when_build_fails_worker.rb


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

# frozen_string_literal: true
module Ci
  module MergeRequests
    class AddTodoWhenBuildFailsWorker
      include ApplicationWorker
      include PipelineQueue

      urgency :low
      idempotent!

      def perform(job_id)
        job = ::CommitStatus.with_pipeline.find_by_id(job_id)
        project = job&.project

        return unless job && project

        ::MergeRequests::AddTodoWhenBuildFailsService.new(job.project, nil).execute(job)
      end
    end
  end
end