Add latest changes from gitlab-org/gitlab@master

app/workers/expire_pipeline_cache_worker.rb

@@ -5,6 +5,8 @@ class ExpirePipelineCacheWorker
   include PipelineQueue
   queue_namespace :pipeline_cache
+  latency_sensitive_worker!
+  worker_resource_boundary :cpu
   # rubocop: disable CodeReuse/ActiveRecord
   def perform(pipeline_id)

app/workers/gitlab_shell_worker.rb

@@ -5,6 +5,7 @@ class GitlabShellWorker
   include Gitlab::ShellAdapter
   feature_category :source_code_management
+  latency_sensitive_worker!
   def perform(action, *arg)
     gitlab_shell.__send__(action, *arg) # rubocop:disable GitlabSecurity/PublicSend

app/workers/import_issues_csv_worker.rb

@@ -4,6 +4,7 @@ class ImportIssuesCsvWorker
   include ApplicationWorker
   feature_category :issue_tracking
+  worker_resource_boundary :cpu
   sidekiq_retries_exhausted do |job|
     Upload.find(job['args'][2]).destroy

app/workers/mail_scheduler/notification_service_worker.rb

@@ -8,6 +8,7 @@ module MailScheduler
     include MailSchedulerQueue
     feature_category :issue_tracking
+    worker_resource_boundary :cpu
     def perform(meth, *args)
       check_arguments!(args)

app/workers/merge_worker.rb

@@ -4,6 +4,7 @@ class MergeWorker
   include ApplicationWorker
   feature_category :source_code_management
+  latency_sensitive_worker!
   def perform(merge_request_id, current_user_id, params)
     params = params.with_indifferent_access

app/workers/namespaces/prune_aggregation_schedules_worker.rb

@@ -6,6 +6,7 @@ module Namespaces
     include CronjobQueue
     feature_category :source_code_management
+    worker_resource_boundary :cpu
     # Worker to prune pending rows on Namespace::AggregationSchedule
     # It's scheduled to run once a day at 1:05am.

app/workers/new_issue_worker.rb

@@ -5,6 +5,8 @@ class NewIssueWorker
   include NewIssuable
   feature_category :issue_tracking
+  latency_sensitive_worker!
+  worker_resource_boundary :cpu
   def perform(issue_id, user_id)
     return unless objects_found?(issue_id, user_id)

app/workers/new_merge_request_worker.rb

@@ -5,6 +5,8 @@ class NewMergeRequestWorker
   include NewIssuable
   feature_category :source_code_management
+  latency_sensitive_worker!
+  worker_resource_boundary :cpu
   def perform(merge_request_id, user_id)
     return unless objects_found?(merge_request_id, user_id)

app/workers/new_note_worker.rb

@@ -4,6 +4,8 @@ class NewNoteWorker
   include ApplicationWorker
   feature_category :issue_tracking
+  latency_sensitive_worker!
+  worker_resource_boundary :cpu
   # Keep extra parameter to preserve backwards compatibility with
   # old `NewNoteWorker` jobs (can remove later)

app/workers/object_pool/join_worker.rb

@@ -5,6 +5,8 @@ module ObjectPool
     include ApplicationWorker
     include ObjectPoolQueue
+    worker_resource_boundary :cpu
+
     # The use of pool id is deprecated. Keeping the argument allows old jobs to
     # still be performed.
     def perform(_pool_id, project_id)

app/workers/pages_domain_removal_cron_worker.rb

@@ -5,6 +5,7 @@ class PagesDomainRemovalCronWorker
   include CronjobQueue
   feature_category :pages
+  worker_resource_boundary :cpu
   def perform
     PagesDomain.for_removal.find_each do |domain|

app/workers/pipeline_hooks_worker.rb

@@ -5,6 +5,8 @@ class PipelineHooksWorker
   include PipelineQueue
   queue_namespace :pipeline_hooks
+  latency_sensitive_worker!
+  worker_resource_boundary :cpu
   # rubocop: disable CodeReuse/ActiveRecord
   def perform(pipeline_id)

app/workers/pipeline_metrics_worker.rb

@@ -4,6 +4,8 @@ class PipelineMetricsWorker
   include ApplicationWorker
   include PipelineQueue
+  latency_sensitive_worker!
+
   # rubocop: disable CodeReuse/ActiveRecord
   def perform(pipeline_id)
     Ci::Pipeline.find_by(id: pipeline_id).try do |pipeline|

app/workers/pipeline_notification_worker.rb

@@ -4,6 +4,9 @@ class PipelineNotificationWorker
   include ApplicationWorker
   include PipelineQueue
+  latency_sensitive_worker!
+  worker_resource_boundary :cpu
+
   # rubocop: disable CodeReuse/ActiveRecord
   def perform(pipeline_id, recipients = nil)
     pipeline = Ci::Pipeline.find_by(id: pipeline_id)

app/workers/pipeline_process_worker.rb

@@ -6,6 +6,7 @@ class PipelineProcessWorker
   queue_namespace :pipeline_processing
   feature_category :continuous_integration
+  latency_sensitive_worker!
   # rubocop: disable CodeReuse/ActiveRecord
   def perform(pipeline_id, build_ids = nil)

app/workers/pipeline_schedule_worker.rb

@@ -5,6 +5,7 @@ class PipelineScheduleWorker
   include CronjobQueue
   feature_category :continuous_integration
+  worker_resource_boundary :cpu
   def perform
     Ci::PipelineSchedule.runnable_schedules.preloaded.find_in_batches do |schedules|

app/workers/pipeline_success_worker.rb

@@ -5,6 +5,7 @@ class PipelineSuccessWorker
   include PipelineQueue
   queue_namespace :pipeline_processing
+  latency_sensitive_worker!
   def perform(pipeline_id)
     # no-op

app/workers/pipeline_update_worker.rb

@@ -5,6 +5,7 @@ class PipelineUpdateWorker
   include PipelineQueue
   queue_namespace :pipeline_processing
+  latency_sensitive_worker!
   # rubocop: disable CodeReuse/ActiveRecord
   def perform(pipeline_id)

app/workers/post_receive.rb

@@ -4,6 +4,8 @@ class PostReceive
   include ApplicationWorker
   feature_category :source_code_management
+  latency_sensitive_worker!
+  worker_resource_boundary :cpu
   def perform(gl_repository, identifier, changes, push_options = {})
     project, repo_type = Gitlab::GlRepository.parse(gl_repository)

app/workers/process_commit_worker.rb

@@ -11,6 +11,7 @@ class ProcessCommitWorker
   include ApplicationWorker
   feature_category :source_code_management
+  latency_sensitive_worker!
   # project_id - The ID of the project this commit belongs to.
   # user_id - The ID of the user that pushed the commit.