summaryrefslogtreecommitdiff
path: root/app/services/ci/enqueue_job_service.rb
diff options
context:
space:
mode:
authorGitLab Bot <gitlab-bot@gitlab.com>2022-12-20 14:22:11 +0000
committerGitLab Bot <gitlab-bot@gitlab.com>2022-12-20 14:22:11 +0000
commit0c872e02b2c822e3397515ec324051ff540f0cd5 (patch)
treece2fb6ce7030e4dad0f4118d21ab6453e5938cdd /app/services/ci/enqueue_job_service.rb
parentf7e05a6853b12f02911494c4b3fe53d9540d74fc (diff)
downloadgitlab-ce-15.7.0-rc42.tar.gz
Add latest changes from gitlab-org/gitlab@15-7-stable-eev15.7.0-rc42
Diffstat (limited to 'app/services/ci/enqueue_job_service.rb')
-rw-r--r--app/services/ci/enqueue_job_service.rb25
1 files changed, 25 insertions, 0 deletions
diff --git a/app/services/ci/enqueue_job_service.rb b/app/services/ci/enqueue_job_service.rb
new file mode 100644
index 00000000000..9e3bea3fd28
--- /dev/null
+++ b/app/services/ci/enqueue_job_service.rb
@@ -0,0 +1,25 @@
+# frozen_string_literal: true
+
+module Ci
+ class EnqueueJobService
+ attr_accessor :job, :current_user, :variables
+
+ def initialize(job, current_user:, variables: nil)
+ @job = job
+ @current_user = current_user
+ @variables = variables
+ end
+
+ def execute(&transition)
+ job.user = current_user
+ job.job_variables_attributes = variables if variables
+
+ transition ||= ->(job) { job.enqueue! }
+ Gitlab::OptimisticLocking.retry_lock(job, name: 'ci_enqueue_job', &transition)
+
+ ResetSkippedJobsService.new(job.project, current_user).execute(job)
+
+ job
+ end
+ end
+end