From e0cfa9279cc8620f64bfceebc743a8c245be215c Mon Sep 17 00:00:00 2001
From: Shinya Maeda <shinya@gitlab.com>
Date: Tue, 25 Sep 2018 14:30:11 +0900
Subject: [PATCH] Execute the worker in pipeline_processing queue

---
 app/workers/ci/build_schedule_worker.rb | 4 ++++
 1 file changed, 4 insertions(+)

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