summaryrefslogtreecommitdiff
path: root/app/workers
diff options
context:
space:
mode:
authorShinya Maeda <shinya@gitlab.com>2018-09-25 14:30:11 +0900
committerAlessio Caiazza <acaiazza@gitlab.com>2018-10-02 17:04:04 +0200
commite0cfa9279cc8620f64bfceebc743a8c245be215c (patch)
tree0341b08873a49287c4958ecdc428674c1faf2274 /app/workers
parentc6e4b6a7d9afd3c8561bc1cddebf8dd05f5534ae (diff)
downloadgitlab-ce-e0cfa9279cc8620f64bfceebc743a8c245be215c.tar.gz
Execute the worker in pipeline_processing queue
Diffstat (limited to 'app/workers')
-rw-r--r--app/workers/ci/build_schedule_worker.rb4
1 files changed, 4 insertions, 0 deletions
diff --git a/app/workers/ci/build_schedule_worker.rb b/app/workers/ci/build_schedule_worker.rb
index 2a2d2bff282..da219adffc6 100644
--- a/app/workers/ci/build_schedule_worker.rb
+++ b/app/workers/ci/build_schedule_worker.rb
@@ -5,8 +5,12 @@ module Ci
include ApplicationWorker
include PipelineQueue
+ queue_namespace :pipeline_processing
+
def perform(build_id)
::Ci::Build.find_by_id(build_id).try do |build|
+ break unless build.scheduled?
+
Ci::RunScheduledBuildService
.new(build.project, build.user).execute(build)
end