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