summaryrefslogtreecommitdiff
path: root/app/workers
diff options
context:
space:
mode:
authorGrzegorz Bizon <grzesiek.bizon@gmail.com>2017-08-21 14:24:05 +0200
committerGrzegorz Bizon <grzesiek.bizon@gmail.com>2017-08-21 14:24:05 +0200
commitad12ee2a78ed590194661b3d5365b0eaa14bff80 (patch)
treede87b1a01e850f19b9e1283365a02102b247b9a7 /app/workers
parent4c93668202f8b3a02e3730e696e9ebcd6f08daca (diff)
downloadgitlab-ce-ad12ee2a78ed590194661b3d5365b0eaa14bff80.tar.gz
Assign some CI/CD workers to pipeline default queue
Diffstat (limited to 'app/workers')
-rw-r--r--app/workers/build_coverage_worker.rb2
-rw-r--r--app/workers/pipeline_metrics_worker.rb2
-rw-r--r--app/workers/pipeline_notification_worker.rb2
3 files changed, 0 insertions, 6 deletions
diff --git a/app/workers/build_coverage_worker.rb b/app/workers/build_coverage_worker.rb
index fd5ba11f73e..cd4af85d047 100644
--- a/app/workers/build_coverage_worker.rb
+++ b/app/workers/build_coverage_worker.rb
@@ -2,8 +2,6 @@ class BuildCoverageWorker
include Sidekiq::Worker
include PipelineQueue
- enqueue_in group: :processing
-
def perform(build_id)
Ci::Build.find_by(id: build_id)&.update_coverage
end
diff --git a/app/workers/pipeline_metrics_worker.rb b/app/workers/pipeline_metrics_worker.rb
index 3795105ef28..070943f1ecc 100644
--- a/app/workers/pipeline_metrics_worker.rb
+++ b/app/workers/pipeline_metrics_worker.rb
@@ -2,8 +2,6 @@ class PipelineMetricsWorker
include Sidekiq::Worker
include PipelineQueue
- enqueue_in group: :metrics
-
def perform(pipeline_id)
Ci::Pipeline.find_by(id: pipeline_id).try do |pipeline|
update_metrics_for_active_pipeline(pipeline) if pipeline.active?
diff --git a/app/workers/pipeline_notification_worker.rb b/app/workers/pipeline_notification_worker.rb
index 77ff3913ad7..cdb860b6675 100644
--- a/app/workers/pipeline_notification_worker.rb
+++ b/app/workers/pipeline_notification_worker.rb
@@ -2,8 +2,6 @@ class PipelineNotificationWorker
include Sidekiq::Worker
include PipelineQueue
- enqueue_in group: :hooks
-
def perform(pipeline_id, recipients = nil)
pipeline = Ci::Pipeline.find_by(id: pipeline_id)