Commit ad12ee2a authored by Grzegorz Bizon's avatar Grzegorz Bizon

Assign some CI/CD workers to pipeline default queue

parent 4c936682
...@@ -2,8 +2,6 @@ class BuildCoverageWorker ...@@ -2,8 +2,6 @@ class BuildCoverageWorker
include Sidekiq::Worker include Sidekiq::Worker
include PipelineQueue include PipelineQueue
enqueue_in group: :processing
def perform(build_id) def perform(build_id)
Ci::Build.find_by(id: build_id)&.update_coverage Ci::Build.find_by(id: build_id)&.update_coverage
end end
......
...@@ -2,8 +2,6 @@ class PipelineMetricsWorker ...@@ -2,8 +2,6 @@ class PipelineMetricsWorker
include Sidekiq::Worker include Sidekiq::Worker
include PipelineQueue include PipelineQueue
enqueue_in group: :metrics
def perform(pipeline_id) def perform(pipeline_id)
Ci::Pipeline.find_by(id: pipeline_id).try do |pipeline| Ci::Pipeline.find_by(id: pipeline_id).try do |pipeline|
update_metrics_for_active_pipeline(pipeline) if pipeline.active? update_metrics_for_active_pipeline(pipeline) if pipeline.active?
......
...@@ -2,8 +2,6 @@ class PipelineNotificationWorker ...@@ -2,8 +2,6 @@ class PipelineNotificationWorker
include Sidekiq::Worker include Sidekiq::Worker
include PipelineQueue include PipelineQueue
enqueue_in group: :hooks
def perform(pipeline_id, recipients = nil) def perform(pipeline_id, recipients = nil)
pipeline = Ci::Pipeline.find_by(id: pipeline_id) pipeline = Ci::Pipeline.find_by(id: pipeline_id)
......
...@@ -28,8 +28,8 @@ ...@@ -28,8 +28,8 @@
- [build, 2] - [build, 2]
- [pipeline, 2] - [pipeline, 2]
- [pipeline_processing, 2] - [pipeline_processing, 2]
- [pipeline_default, 2]
- [pipeline_cache, 2] - [pipeline_cache, 2]
- [pipeline_metrics, 2]
- [pipeline_hooks, 2] - [pipeline_hooks, 2]
- [gitlab_shell, 2] - [gitlab_shell, 2]
- [email_receiver, 2] - [email_receiver, 2]
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment