Add exclude_from_kubernetes tag to workers we run on VMs

Most of these workers probably would be fine to run on K8s; this is just to make the current state (as encoded in our Sidekiq configuration for GitLab.com) explicit.

Add exclude_from_kubernetes tag to workers we run on VMs
Most of these workers probably would be fine to run on K8s; this is just to make the current state (as encoded in our Sidekiq configuration for GitLab.com) explicit.
abe0b763 · Sean McGivern · 4a61262a · abe0b763 · abe0b763 · abe0b763
Commit abe0b763 authored Apr 28, 2021 by Sean McGivern
111 changed files
--- a/app/workers/all_queues.yml
+++ b/app/workers/all_queues.yml
--- a/app/workers/analytics/instance_statistics/count_job_trigger_worker.rb
+++ b/app/workers/analytics/instance_statistics/count_job_trigger_worker.rb
@@ -8,6 +8,7 @@ module Analytics
      include CronjobQueue # rubocop:disable Scalability/CronWorkerContext

      feature_category :devops_reports
+      tags :exclude_from_kubernetes
      urgency :low

      idempotent!

--- a/app/workers/analytics/instance_statistics/counter_job_worker.rb
+++ b/app/workers/analytics/instance_statistics/counter_job_worker.rb
@@ -8,6 +8,7 @@ module Analytics

      feature_category :devops_reports
      urgency :low
+      tags :exclude_from_kubernetes

      idempotent!


--- a/app/workers/analytics/usage_trends/count_job_trigger_worker.rb
+++ b/app/workers/analytics/usage_trends/count_job_trigger_worker.rb
@@ -10,6 +10,7 @@ module Analytics
      DEFAULT_DELAY = 3.minutes.freeze

      feature_category :devops_reports
+      tags :exclude_from_kubernetes
      urgency :low

      idempotent!

--- a/app/workers/analytics/usage_trends/counter_job_worker.rb
+++ b/app/workers/analytics/usage_trends/counter_job_worker.rb
@@ -8,6 +8,7 @@ module Analytics

      feature_category :devops_reports
      urgency :low
+      tags :exclude_from_kubernetes

      idempotent!


--- a/app/workers/approve_blocked_pending_approval_users_worker.rb
+++ b/app/workers/approve_blocked_pending_approval_users_worker.rb
@@ -6,6 +6,7 @@ class ApproveBlockedPendingApprovalUsersWorker
  idempotent!

  feature_category :users
+  tags :exclude_from_kubernetes

  def perform(current_user_id)
    current_user = User.find(current_user_id)

--- a/app/workers/bulk_import_worker.rb
+++ b/app/workers/bulk_import_worker.rb
@@ -4,6 +4,7 @@ class BulkImportWorker # rubocop:disable Scalability/IdempotentWorker
  include ApplicationWorker

  feature_category :importers
+  tags :exclude_from_kubernetes

  sidekiq_options retry: false, dead: false


--- a/app/workers/bulk_imports/entity_worker.rb
+++ b/app/workers/bulk_imports/entity_worker.rb
@@ -5,6 +5,7 @@ module BulkImports
    include ApplicationWorker

    feature_category :importers
+    tags :exclude_from_kubernetes

    sidekiq_options retry: false, dead: false


--- a/app/workers/bulk_imports/pipeline_worker.rb
+++ b/app/workers/bulk_imports/pipeline_worker.rb
@@ -5,6 +5,7 @@ module BulkImports
    include ApplicationWorker

    feature_category :importers
+    tags :exclude_from_kubernetes

    sidekiq_options retry: false, dead: false


--- a/app/workers/ci/delete_objects_worker.rb
+++ b/app/workers/ci/delete_objects_worker.rb
@@ -6,6 +6,7 @@ module Ci
    include LimitedCapacity::Worker

    feature_category :continuous_integration
+    tags :exclude_from_kubernetes
    idempotent!

    def perform_work(*args)

--- a/app/workers/ci/drop_pipeline_worker.rb
+++ b/app/workers/ci/drop_pipeline_worker.rb
@@ -5,6 +5,8 @@ module Ci
    include ApplicationWorker
    include PipelineQueue

+    tags :exclude_from_kubernetes
+
    idempotent!

    def perform(pipeline_id, failure_reason)

--- a/app/workers/ci/merge_requests/add_todo_when_build_fails_worker.rb
+++ b/app/workers/ci/merge_requests/add_todo_when_build_fails_worker.rb
@@ -6,6 +6,7 @@ module Ci
      include PipelineQueue

      urgency :low
+      tags :exclude_from_kubernetes
      idempotent!

      def perform(job_id)

--- a/app/workers/ci/pipeline_artifacts/coverage_report_worker.rb
+++ b/app/workers/ci/pipeline_artifacts/coverage_report_worker.rb
@@ -7,6 +7,7 @@ module Ci
      include PipelineBackgroundQueue

      feature_category :code_testing
+      tags :exclude_from_kubernetes

      idempotent!


--- a/app/workers/ci/pipeline_artifacts/create_quality_report_worker.rb
+++ b/app/workers/ci/pipeline_artifacts/create_quality_report_worker.rb
@@ -7,6 +7,7 @@ module Ci

      queue_namespace :pipeline_background
      feature_category :code_testing
+      tags :exclude_from_kubernetes

      idempotent!


--- a/app/workers/ci/pipeline_artifacts/expire_artifacts_worker.rb
+++ b/app/workers/ci/pipeline_artifacts/expire_artifacts_worker.rb
@@ -12,6 +12,7 @@ module Ci
      deduplicate :until_executed, including_scheduled: true
      idempotent!
      feature_category :continuous_integration
+      tags :exclude_from_kubernetes

      def perform
        service = ::Ci::PipelineArtifacts::DestroyAllExpiredService.new

--- a/app/workers/ci/schedule_delete_objects_cron_worker.rb
+++ b/app/workers/ci/schedule_delete_objects_cron_worker.rb
@@ -9,6 +9,7 @@ module Ci
    # rubocop:enable Scalability/CronWorkerContext

    feature_category :continuous_integration
+    tags :exclude_from_kubernetes
    idempotent!

    def perform(*args)

--- a/app/workers/ci/test_failure_history_worker.rb
+++ b/app/workers/ci/test_failure_history_worker.rb
@@ -5,6 +5,8 @@ module Ci
    include ApplicationWorker
    include PipelineBackgroundQueue

+    tags :exclude_from_kubernetes
+
    idempotent!

    def perform(pipeline_id)

--- a/app/workers/container_expiration_policies/cleanup_container_repository_worker.rb
+++ b/app/workers/container_expiration_policies/cleanup_container_repository_worker.rb
@@ -8,6 +8,7 @@ module ContainerExpirationPolicies

    queue_namespace :container_repository
    feature_category :container_registry
+    tags :exclude_from_kubernetes
    urgency :low
    worker_resource_boundary :unknown
    idempotent!

--- a/app/workers/database/batched_background_migration_worker.rb
+++ b/app/workers/database/batched_background_migration_worker.rb
@@ -6,6 +6,7 @@ module Database
    include CronjobQueue # rubocop:disable Scalability/CronWorkerContext

    feature_category :database
+    tags :exclude_from_kubernetes
    idempotent!

    LEASE_TIMEOUT_MULTIPLIER = 3

--- a/app/workers/deployments/drop_older_deployments_worker.rb
+++ b/app/workers/deployments/drop_older_deployments_worker.rb
@@ -6,6 +6,7 @@ module Deployments

    queue_namespace :deployment
    feature_category :continuous_delivery
+    tags :exclude_from_kubernetes

    def perform(deployment_id)
      Deployments::OlderDeploymentsDropService.new(deployment_id).execute

--- a/app/workers/design_management/copy_design_collection_worker.rb
+++ b/app/workers/design_management/copy_design_collection_worker.rb
@@ -5,6 +5,7 @@ module DesignManagement
    include ApplicationWorker

    feature_category :design_management
+    tags :exclude_from_kubernetes
    idempotent!
    urgency :low


--- a/app/workers/destroy_pages_deployments_worker.rb
+++ b/app/workers/destroy_pages_deployments_worker.rb
@@ -8,6 +8,7 @@ class DestroyPagesDeploymentsWorker
  loggable_arguments 0, 1
  sidekiq_options retry: 3
  feature_category :pages
+  tags :exclude_from_kubernetes

  def perform(project_id, last_deployment_id = nil)
    project = Project.find_by_id(project_id)

--- a/app/workers/disallow_two_factor_for_group_worker.rb
+++ b/app/workers/disallow_two_factor_for_group_worker.rb
@@ -5,6 +5,7 @@ class DisallowTwoFactorForGroupWorker
  include ExceptionBacktrace

  feature_category :subgroups
+  tags :exclude_from_kubernetes
  idempotent!

  def perform(group_id)

--- a/app/workers/disallow_two_factor_for_subgroups_worker.rb
+++ b/app/workers/disallow_two_factor_for_subgroups_worker.rb
@@ -7,6 +7,7 @@ class DisallowTwoFactorForSubgroupsWorker
  INTERVAL = 2.seconds.to_i

  feature_category :subgroups
+  tags :exclude_from_kubernetes
  idempotent!

  def perform(group_id)

--- a/app/workers/environments/canary_ingress/update_worker.rb
+++ b/app/workers/environments/canary_ingress/update_worker.rb
@@ -9,6 +9,7 @@ module Environments
      idempotent!
      worker_has_external_dependencies!
      feature_category :continuous_delivery
+      tags :exclude_from_kubernetes

      def perform(environment_id, params)
        Environment.find_by_id(environment_id).try do |environment|

--- a/app/workers/experiments/record_conversion_event_worker.rb
+++ b/app/workers/experiments/record_conversion_event_worker.rb
@@ -5,6 +5,7 @@ module Experiments
    include ApplicationWorker

    feature_category :users
+    tags :exclude_from_kubernetes
    urgency :low

    idempotent!

--- a/app/workers/flush_counter_increments_worker.rb
+++ b/app/workers/flush_counter_increments_worker.rb
@@ -9,6 +9,7 @@ class FlushCounterIncrementsWorker
  include ApplicationWorker

  feature_category_not_owned!
+  tags :exclude_from_kubernetes
  urgency :low
  deduplicate :until_executing, including_scheduled: true


--- a/app/workers/gitlab/github_import/import_pull_request_merged_by_worker.rb
+++ b/app/workers/gitlab/github_import/import_pull_request_merged_by_worker.rb
@@ -5,6 +5,8 @@ module Gitlab
    class ImportPullRequestMergedByWorker # rubocop:disable Scalability/IdempotentWorker
      include ObjectImporter

+      tags :exclude_from_kubernetes
+
      def representation_class
        Gitlab::GithubImport::Representation::PullRequest
      end

--- a/app/workers/gitlab/github_import/import_pull_request_review_worker.rb
+++ b/app/workers/gitlab/github_import/import_pull_request_review_worker.rb
@@ -5,6 +5,8 @@ module Gitlab
    class ImportPullRequestReviewWorker # rubocop:disable Scalability/IdempotentWorker
      include ObjectImporter

+      tags :exclude_from_kubernetes
+
      def representation_class
        Gitlab::GithubImport::Representation::PullRequestReview
      end

--- a/app/workers/gitlab/github_import/stage/import_pull_requests_merged_by_worker.rb
+++ b/app/workers/gitlab/github_import/stage/import_pull_requests_merged_by_worker.rb
@@ -8,6 +8,8 @@ module Gitlab
        include GithubImport::Queue
        include StageMethods

+        tags :exclude_from_kubernetes
+
        # client - An instance of Gitlab::GithubImport::Client.
        # project - An instance of Project.
        def import(client, project)

--- a/app/workers/gitlab/github_import/stage/import_pull_requests_reviews_worker.rb
+++ b/app/workers/gitlab/github_import/stage/import_pull_requests_reviews_worker.rb
@@ -8,6 +8,8 @@ module Gitlab
        include GithubImport::Queue
        include StageMethods

+        tags :exclude_from_kubernetes
+
        # client - An instance of Gitlab::GithubImport::Client.
        # project - An instance of Project.
        def import(client, project)

--- a/app/workers/gitlab_performance_bar_stats_worker.rb
+++ b/app/workers/gitlab_performance_bar_stats_worker.rb
@@ -10,6 +10,7 @@ class GitlabPerformanceBarStatsWorker
  STATS_KEY_EXPIRE = 30.minutes.to_i

  feature_category :metrics
+  tags :exclude_from_kubernetes
  idempotent!

  def perform(lease_uuid)

--- a/app/workers/group_destroy_worker.rb
+++ b/app/workers/group_destroy_worker.rb
@@ -5,7 +5,7 @@ class GroupDestroyWorker # rubocop:disable Scalability/IdempotentWorker
  include ExceptionBacktrace

  feature_category :subgroups
-  tags :requires_disk_io
+  tags :requires_disk_io, :exclude_from_kubernetes

  def perform(group_id, user_id)
    begin

--- a/app/workers/incident_management/add_severity_system_note_worker.rb
+++ b/app/workers/incident_management/add_severity_system_note_worker.rb
@@ -6,6 +6,7 @@ module IncidentManagement

    queue_namespace :incident_management
    feature_category :incident_management
+    tags :exclude_from_kubernetes

    def perform(incident_id, user_id)
      return if incident_id.blank? || user_id.blank?

--- a/app/workers/issue_rebalancing_worker.rb
+++ b/app/workers/issue_rebalancing_worker.rb
@@ -6,6 +6,7 @@ class IssueRebalancingWorker
  idempotent!
  urgency :low
  feature_category :issue_tracking
+  tags :exclude_from_kubernetes

  def perform(ignore = nil, project_id = nil)
    return if project_id.nil?

--- a/app/workers/jira_connect/sync_builds_worker.rb
+++ b/app/workers/jira_connect/sync_builds_worker.rb
@@ -9,6 +9,7 @@ module JiraConnect

    queue_namespace :jira_connect
    feature_category :integrations
+    tags :exclude_from_kubernetes

    def perform(pipeline_id, sequence_id)
      pipeline = Ci::Pipeline.find_by_id(pipeline_id)

--- a/app/workers/jira_connect/sync_deployments_worker.rb
+++ b/app/workers/jira_connect/sync_deployments_worker.rb
@@ -9,6 +9,7 @@ module JiraConnect

    queue_namespace :jira_connect
    feature_category :integrations
+    tags :exclude_from_kubernetes

    def perform(deployment_id, sequence_id)
      deployment = Deployment.find_by_id(deployment_id)

--- a/app/workers/jira_connect/sync_feature_flags_worker.rb
+++ b/app/workers/jira_connect/sync_feature_flags_worker.rb
@@ -9,6 +9,7 @@ module JiraConnect

    queue_namespace :jira_connect
    feature_category :integrations
+    tags :exclude_from_kubernetes

    def perform(feature_flag_id, sequence_id)
      feature_flag = ::Operations::FeatureFlag.find_by_id(feature_flag_id)

--- a/app/workers/jira_connect/sync_project_worker.rb
+++ b/app/workers/jira_connect/sync_project_worker.rb
@@ -6,6 +6,7 @@ module JiraConnect

    queue_namespace :jira_connect
    feature_category :integrations
+    tags :exclude_from_kubernetes
    idempotent!
    worker_has_external_dependencies!


--- a/app/workers/member_invitation_reminder_emails_worker.rb
+++ b/app/workers/member_invitation_reminder_emails_worker.rb
@@ -5,6 +5,7 @@ class MemberInvitationReminderEmailsWorker # rubocop:disable Scalability/Idempot
  include CronjobQueue # rubocop:disable Scalability/CronWorkerContext

  feature_category :subgroups
+  tags :exclude_from_kubernetes
  urgency :low

  def perform

--- a/app/workers/merge_request_cleanup_refs_worker.rb
+++ b/app/workers/merge_request_cleanup_refs_worker.rb
@@ -4,6 +4,7 @@ class MergeRequestCleanupRefsWorker
  include ApplicationWorker

  feature_category :code_review
+  tags :exclude_from_kubernetes
  idempotent!

  def perform(merge_request_id)

--- a/app/workers/metrics/dashboard/sync_dashboards_worker.rb
+++ b/app/workers/metrics/dashboard/sync_dashboards_worker.rb
@@ -6,6 +6,7 @@ module Metrics
      include ApplicationWorker

      feature_category :metrics
+      tags :exclude_from_kubernetes

      idempotent!


--- a/app/workers/namespaces/in_product_marketing_emails_worker.rb
+++ b/app/workers/namespaces/in_product_marketing_emails_worker.rb
@@ -6,6 +6,7 @@ module Namespaces
    include CronjobQueue # rubocop:disable Scalability/CronWorkerContext

    feature_category :subgroups
+    tags :exclude_from_kubernetes
    urgency :low

    def perform

--- a/app/workers/namespaces/onboarding_issue_created_worker.rb
+++ b/app/workers/namespaces/onboarding_issue_created_worker.rb
@@ -5,6 +5,7 @@ module Namespaces
    include ApplicationWorker

    feature_category :issue_tracking
+    tags :exclude_from_kubernetes
    urgency :low

    deduplicate :until_executing

--- a/app/workers/namespaces/onboarding_pipeline_created_worker.rb
+++ b/app/workers/namespaces/onboarding_pipeline_created_worker.rb
@@ -5,6 +5,7 @@ module Namespaces
    include ApplicationWorker

    feature_category :subgroups
+    tags :exclude_from_kubernetes
    urgency :low

    deduplicate :until_executing

--- a/app/workers/namespaces/onboarding_progress_worker.rb
+++ b/app/workers/namespaces/onboarding_progress_worker.rb
@@ -5,6 +5,7 @@ module Namespaces
    include ApplicationWorker

    feature_category :product_analytics
+    tags :exclude_from_kubernetes
    urgency :low

    deduplicate :until_executed

--- a/app/workers/namespaces/onboarding_user_added_worker.rb
+++ b/app/workers/namespaces/onboarding_user_added_worker.rb
@@ -5,6 +5,7 @@ module Namespaces
    include ApplicationWorker

    feature_category :users
+    tags :exclude_from_kubernetes
    urgency :low

    idempotent!

--- a/app/workers/packages/composer/cache_cleanup_worker.rb
+++ b/app/workers/packages/composer/cache_cleanup_worker.rb
@@ -7,6 +7,7 @@ module Packages
      include CronjobQueue # rubocop:disable Scalability/CronWorkerContext

      feature_category :package_registry
+      tags :exclude_from_kubernetes

      idempotent!


--- a/app/workers/packages/composer/cache_update_worker.rb
+++ b/app/workers/packages/composer/cache_update_worker.rb
@@ -6,6 +6,7 @@ module Packages
      include ApplicationWorker

      feature_category :package_registry
+      tags :exclude_from_kubernetes

      idempotent!


--- a/app/workers/packages/debian/process_changes_worker.rb
+++ b/app/workers/packages/debian/process_changes_worker.rb
@@ -11,6 +11,7 @@ module Packages

      queue_namespace :package_repositories
      feature_category :package_registry
+      tags :exclude_from_kubernetes

      def perform(package_file_id, user_id)
        @package_file_id = package_file_id

--- a/app/workers/packages/go/sync_packages_worker.rb
+++ b/app/workers/packages/go/sync_packages_worker.rb
@@ -8,6 +8,7 @@ module Packages

      queue_namespace :package_repositories
      feature_category :package_registry
+      tags :exclude_from_kubernetes

      deduplicate :until_executing
      idempotent!

--- a/app/workers/packages/maven/metadata/sync_worker.rb
+++ b/app/workers/packages/maven/metadata/sync_worker.rb
@@ -9,6 +9,7 @@ module Packages

        queue_namespace :package_repositories
        feature_category :package_registry
+        tags :exclude_from_kubernetes

        deduplicate :until_executing
        idempotent!

--- a/app/workers/packages/rubygems/extraction_worker.rb
+++ b/app/workers/packages/rubygems/extraction_worker.rb
@@ -7,6 +7,7 @@ module Packages

      queue_namespace :package_repositories
      feature_category :package_registry
+      tags :exclude_from_kubernetes
      deduplicate :until_executing

      idempotent!

--- a/app/workers/pages_domain_ssl_renewal_worker.rb
+++ b/app/workers/pages_domain_ssl_renewal_worker.rb
@@ -4,7 +4,7 @@ class PagesDomainSslRenewalWorker # rubocop:disable Scalability/IdempotentWorker
  include ApplicationWorker

  feature_category :pages
-  tags :requires_disk_io
+  tags :requires_disk_io, :exclude_from_kubernetes

  def perform(domain_id)
    domain = PagesDomain.find_by_id(domain_id)

--- a/app/workers/pages_domain_verification_worker.rb
+++ b/app/workers/pages_domain_verification_worker.rb
@@ -4,7 +4,7 @@ class PagesDomainVerificationWorker # rubocop:disable Scalability/IdempotentWork
  include ApplicationWorker

  feature_category :pages
-  tags :requires_disk_io
+  tags :requires_disk_io, :exclude_from_kubernetes

  # rubocop: disable CodeReuse/ActiveRecord
  def perform(domain_id)

--- a/app/workers/pages_remove_worker.rb
+++ b/app/workers/pages_remove_worker.rb
@@ -6,6 +6,7 @@ class PagesRemoveWorker # rubocop:disable Scalability/IdempotentWorker

  sidekiq_options retry: 3
  feature_category :pages
+  tags :exclude_from_kubernetes
  loggable_arguments 0

  def perform(project_id)

--- a/app/workers/pages_transfer_worker.rb
+++ b/app/workers/pages_transfer_worker.rb
@@ -6,6 +6,7 @@ class PagesTransferWorker # rubocop:disable Scalability/IdempotentWorker
  TransferFailedError = Class.new(StandardError)

  feature_category :pages
+  tags :exclude_from_kubernetes
  loggable_arguments 0, 1

  def perform(method, args)

--- a/app/workers/pages_update_configuration_worker.rb
+++ b/app/workers/pages_update_configuration_worker.rb
@@ -5,6 +5,7 @@ class PagesUpdateConfigurationWorker

  idempotent!
  feature_category :pages
+  tags :exclude_from_kubernetes

  def self.perform_async(*args)
    return unless ::Settings.pages.local_store.enabled

--- a/app/workers/pages_worker.rb
+++ b/app/workers/pages_worker.rb
@@ -6,7 +6,7 @@ class PagesWorker # rubocop:disable Scalability/IdempotentWorker
  sidekiq_options retry: 3
  feature_category :pages
  loggable_arguments 0, 1
-  tags :requires_disk_io
+  tags :requires_disk_io, :exclude_from_kubernetes

  def perform(action, *arg)
    send(action, *arg) # rubocop:disable GitlabSecurity/PublicSend

--- a/app/workers/personal_access_tokens/expired_notification_worker.rb
+++ b/app/workers/personal_access_tokens/expired_notification_worker.rb
@@ -6,6 +6,7 @@ module PersonalAccessTokens
    include CronjobQueue

    feature_category :authentication_and_authorization
+    tags :exclude_from_kubernetes

    def perform(*args)
      notification_service = NotificationService.new

--- a/app/workers/project_destroy_worker.rb
+++ b/app/workers/project_destroy_worker.rb
@@ -5,7 +5,7 @@ class ProjectDestroyWorker # rubocop:disable Scalability/IdempotentWorker
  include ExceptionBacktrace

  feature_category :source_code_management
-  tags :requires_disk_io
+  tags :requires_disk_io, :exclude_from_kubernetes

  def perform(project_id, user_id, params)
    project = Project.find(project_id)

--- a/app/workers/projects/git_garbage_collect_worker.rb
+++ b/app/workers/projects/git_garbage_collect_worker.rb
@@ -5,6 +5,8 @@ module Projects
    extend ::Gitlab::Utils::Override
    include GitGarbageCollectMethods

+    tags :exclude_from_kubernetes
+
    private

    override :find_resource

--- a/app/workers/projects/post_creation_worker.rb
+++ b/app/workers/projects/post_creation_worker.rb
@@ -5,6 +5,7 @@ module Projects
    include ApplicationWorker

    feature_category :source_code_management
+    tags :exclude_from_kubernetes
    idempotent!

    def perform(project_id)

--- a/app/workers/propagate_integration_group_worker.rb
+++ b/app/workers/propagate_integration_group_worker.rb
@@ -4,6 +4,7 @@ class PropagateIntegrationGroupWorker
  include ApplicationWorker

  feature_category :integrations
+  tags :exclude_from_kubernetes
  idempotent!

  # rubocop: disable CodeReuse/ActiveRecord

--- a/app/workers/propagate_integration_inherit_descendant_worker.rb
+++ b/app/workers/propagate_integration_inherit_descendant_worker.rb
@@ -4,6 +4,7 @@ class PropagateIntegrationInheritDescendantWorker
  include ApplicationWorker

  feature_category :integrations
+  tags :exclude_from_kubernetes
  idempotent!

  # rubocop: disable CodeReuse/ActiveRecord

--- a/app/workers/propagate_integration_inherit_worker.rb
+++ b/app/workers/propagate_integration_inherit_worker.rb
@@ -4,6 +4,7 @@ class PropagateIntegrationInheritWorker
  include ApplicationWorker

  feature_category :integrations
+  tags :exclude_from_kubernetes
  idempotent!

  # rubocop: disable CodeReuse/ActiveRecord

--- a/app/workers/propagate_integration_project_worker.rb
+++ b/app/workers/propagate_integration_project_worker.rb
@@ -4,6 +4,7 @@ class PropagateIntegrationProjectWorker
  include ApplicationWorker

  feature_category :integrations
+  tags :exclude_from_kubernetes
  idempotent!

  # rubocop: disable CodeReuse/ActiveRecord

--- a/app/workers/releases/create_evidence_worker.rb
+++ b/app/workers/releases/create_evidence_worker.rb
@@ -5,6 +5,7 @@ module Releases
    include ApplicationWorker

    feature_category :release_evidence
+    tags :exclude_from_kubernetes

    # pipeline_id is optional for backward compatibility with existing jobs
    # caller should always try to provide the pipeline and pass nil only

--- a/app/workers/releases/manage_evidence_worker.rb
+++ b/app/workers/releases/manage_evidence_worker.rb
@@ -6,6 +6,7 @@ module Releases
    include CronjobQueue # rubocop:disable Scalability/CronWorkerContext

    feature_category :release_evidence
+    tags :exclude_from_kubernetes

    def perform
      releases = Release.without_evidence.released_within_2hrs

--- a/app/workers/remove_unaccepted_member_invites_worker.rb
+++ b/app/workers/remove_unaccepted_member_invites_worker.rb
@@ -5,6 +5,7 @@ class RemoveUnacceptedMemberInvitesWorker # rubocop:disable Scalability/Idempote
  include CronjobQueue # rubocop:disable Scalability/CronWorkerContext

  feature_category :authentication_and_authorization
+  tags :exclude_from_kubernetes
  urgency :low
  idempotent!


--- a/app/workers/schedule_merge_request_cleanup_refs_worker.rb
+++ b/app/workers/schedule_merge_request_cleanup_refs_worker.rb
@@ -5,6 +5,7 @@ class ScheduleMergeRequestCleanupRefsWorker
  include CronjobQueue # rubocop:disable Scalability/CronWorkerContext

  feature_category :code_review
+  tags :exclude_from_kubernetes
  idempotent!

  # Based on existing data, MergeRequestCleanupRefsWorker can run 3 jobs per

--- a/app/workers/ssh_keys/expired_notification_worker.rb
+++ b/app/workers/ssh_keys/expired_notification_worker.rb
@@ -6,6 +6,7 @@ module SshKeys
    include CronjobQueue

    feature_category :compliance_management
+    tags :exclude_from_kubernetes
    idempotent!

    def perform

--- a/app/workers/ssh_keys/expiring_soon_notification_worker.rb
+++ b/app/workers/ssh_keys/expiring_soon_notification_worker.rb
@@ -6,6 +6,7 @@ module SshKeys
    include CronjobQueue

    feature_category :compliance_management
+    tags :exclude_from_kubernetes
    idempotent!

    def perform

--- a/app/workers/todos_destroyer/destroyed_issuable_worker.rb
+++ b/app/workers/todos_destroyer/destroyed_issuable_worker.rb
@@ -5,6 +5,8 @@ module TodosDestroyer
    include ApplicationWorker
    include TodosDestroyerQueue

+    tags :exclude_from_kubernetes
+
    idempotent!

    def perform(target_id, target_type)

--- a/app/workers/user_status_cleanup/batch_worker.rb
+++ b/app/workers/user_status_cleanup/batch_worker.rb
@@ -9,6 +9,7 @@ module UserStatusCleanup
    # rubocop:enable Scalability/CronWorkerContext

    feature_category :users
+    tags :exclude_from_kubernetes

    idempotent!


--- a/app/workers/users/deactivate_dormant_users_worker.rb
+++ b/app/workers/users/deactivate_dormant_users_worker.rb
@@ -6,6 +6,7 @@ module Users
    include CronjobQueue

    feature_category :utilization
+    tags :exclude_from_kubernetes

    NUMBER_OF_BATCHES = 50
    BATCH_SIZE = 200

--- a/app/workers/users/update_open_issue_count_worker.rb
+++ b/app/workers/users/update_open_issue_count_worker.rb
@@ -5,6 +5,7 @@ module Users
    include ApplicationWorker

    feature_category :users
+    tags :exclude_from_kubernetes
    idempotent!

    def perform(target_user_ids)

--- a/app/workers/web_hooks/destroy_worker.rb
+++ b/app/workers/web_hooks/destroy_worker.rb
@@ -5,6 +5,7 @@ module WebHooks
    include ApplicationWorker

    feature_category :integrations
+    tags :exclude_from_kubernetes
    urgency :low
    idempotent!


--- a/app/workers/wikis/git_garbage_collect_worker.rb
+++ b/app/workers/wikis/git_garbage_collect_worker.rb
@@ -5,6 +5,8 @@ module Wikis
    extend ::Gitlab::Utils::Override
    include GitGarbageCollectMethods

+    tags :exclude_from_kubernetes
+
    private

    override :find_resource

--- a/ee/app/workers/active_user_count_threshold_worker.rb
+++ b/ee/app/workers/active_user_count_threshold_worker.rb
@@ -8,6 +8,7 @@ class ActiveUserCountThresholdWorker # rubocop:disable Scalability/IdempotentWor
  # rubocop:enable Scalability/CronWorkerContext

  feature_category :license
+  tags :exclude_from_kubernetes

  def perform
    License.with_valid_license do |license|

--- a/ee/app/workers/all_queues.yml
+++ b/ee/app/workers/all_queues.yml
@@ -18,7 +18,8 @@
  :resource_boundary: :unknown
  :weight: 1
  :idempotent:
-  :tags: []
+  :tags:
+  - :exclude_from_kubernetes
 - :name: cronjob:adjourned_group_deletion
  :feature_category: :authentication_and_authorization
  :has_external_dependencies:
@@ -42,7 +43,8 @@
  :resource_boundary: :unknown
  :weight: 1
  :idempotent: true
-  :tags: []
+  :tags:
+  - :exclude_from_kubernetes
 - :name: cronjob:clear_shared_runners_minutes
  :feature_category: :continuous_integration
  :has_external_dependencies:
@@ -90,7 +92,8 @@
  :resource_boundary: :unknown
  :weight: 1
  :idempotent: true
-  :tags: []
+  :tags:
+  - :exclude_from_kubernetes
 - :name: cronjob:geo_container_repository_sync_dispatch
  :feature_category: :geo_replication
  :has_external_dependencies:
@@ -202,7 +205,8 @@
  :resource_boundary: :unknown
  :weight: 1
  :idempotent:
-  :tags: []
+  :tags:
+  - :exclude_from_kubernetes
 - :name: cronjob:geo_sidekiq_cron_config
  :feature_category: :geo_replication
  :has_external_dependencies:
@@ -218,7 +222,8 @@
  :resource_boundary: :unknown
  :weight: 1
  :idempotent: true
-  :tags: []
+  :tags:
+  - :exclude_from_kubernetes
 - :name: cronjob:geo_verification_cron
  :feature_category: :geo_replication
  :has_external_dependencies:
@@ -226,7 +231,8 @@
  :resource_boundary: :unknown
  :weight: 1
  :idempotent: true
-  :tags: []
+  :tags:
+  - :exclude_from_kubernetes
 - :name: cronjob:historical_data
  :feature_category: :utilization
  :has_external_dependencies:
@@ -250,7 +256,8 @@
  :resource_boundary: :unknown
  :weight: 1
  :idempotent: true
-  :tags: []
+  :tags:
+  - :exclude_from_kubernetes
 - :name: cronjob:incident_management_oncall_rotations_persist_all_rotations_shifts_job
  :feature_category: :incident_management
  :has_external_dependencies:
@@ -258,7 +265,8 @@
  :resource_boundary: :unknown
  :weight: 1
  :idempotent: true
-  :tags: []
+  :tags:
+  - :exclude_from_kubernetes
 - :name: cronjob:ingress_modsecurity_counter_metrics
  :feature_category: :web_firewall
  :has_external_dependencies: true
@@ -338,7 +346,8 @@
  :resource_boundary: :unknown
  :weight: 1
  :idempotent:
-  :tags: []
+  :tags:
+  - :exclude_from_kubernetes
 - :name: cronjob:vulnerabilities_statistics_schedule
  :feature_category: :vulnerability_management
  :has_external_dependencies:
@@ -354,7 +363,8 @@
  :resource_boundary: :unknown
  :weight: 3
  :idempotent: true
-  :tags: []
+  :tags:
+  - :exclude_from_kubernetes
 - :name: dora_metrics:dora_daily_metrics_refresh
  :feature_category: :continuous_delivery
  :has_external_dependencies:
@@ -362,7 +372,8 @@
  :resource_boundary: :unknown
  :weight: 1
  :idempotent: true
-  :tags: []
+  :tags:
+  - :exclude_from_kubernetes
 - :name: epics:epics_update_epics_dates
  :feature_category: :epics
  :has_external_dependencies:
@@ -418,7 +429,8 @@
  :resource_boundary: :unknown
  :weight: 1
  :idempotent: true
-  :tags: []
+  :tags:
+  - :exclude_from_kubernetes
 - :name: geo:geo_event
  :feature_category: :geo_replication
  :has_external_dependencies:
@@ -546,7 +558,8 @@
  :resource_boundary: :unknown
  :weight: 1
  :idempotent: true
-  :tags: []
+  :tags:
+  - :exclude_from_kubernetes
 - :name: geo:geo_scheduler_primary_scheduler
  :feature_category: :geo_replication
  :has_external_dependencies:
@@ -578,7 +591,8 @@
  :resource_boundary: :unknown
  :weight: 1
  :idempotent: true
-  :tags: []
+  :tags:
+  - :exclude_from_kubernetes
 - :name: geo:geo_verification_batch
  :feature_category: :geo_replication
  :has_external_dependencies:
@@ -586,7 +600,8 @@
  :resource_boundary: :unknown
  :weight: 1
  :idempotent: true
-  :tags: []
+  :tags:
+  - :exclude_from_kubernetes
 - :name: geo:geo_verification_timeout
  :feature_category: :geo_replication
  :has_external_dependencies:
@@ -594,7 +609,8 @@
  :resource_boundary: :unknown
  :weight: 1
  :idempotent: true
-  :tags: []
+  :tags:
+  - :exclude_from_kubernetes
 - :name: personal_access_tokens:personal_access_tokens_groups_policy
  :feature_category: :authentication_and_authorization
  :has_external_dependencies:
@@ -634,7 +650,8 @@
  :resource_boundary: :unknown
  :weight: 2
  :idempotent:
-  :tags: []
+  :tags:
+  - :exclude_from_kubernetes
 - :name: security_scans:store_security_reports
  :feature_category: :static_application_security_testing
  :has_external_dependencies:
@@ -666,7 +683,8 @@
  :resource_boundary: :unknown
  :weight: 1
  :idempotent:
-  :tags: []
+  :tags:
+  - :exclude_from_kubernetes
 - :name: adjourned_project_deletion
  :feature_category: :authentication_and_authorization
  :has_external_dependencies:
@@ -698,7 +716,8 @@
  :resource_boundary: :unknown
  :weight: 1
  :idempotent: true
-  :tags: []
+  :tags:
+  - :exclude_from_kubernetes
 - :name: approval_rules_external_approval_rule_payload
  :feature_category: :source_code_management
  :has_external_dependencies:
@@ -706,7 +725,8 @@
  :resource_boundary: :unknown
  :weight: 1
  :idempotent: true
-  :tags: []
+  :tags:
+  - :exclude_from_kubernetes
 - :name: ci_batch_reset_minutes
  :feature_category: :continuous_integration
  :has_external_dependencies:
@@ -730,7 +750,8 @@
  :resource_boundary: :unknown
  :weight: 1
  :idempotent: true
-  :tags: []
+  :tags:
+  - :exclude_from_kubernetes
 - :name: elastic_association_indexer
  :feature_category: :global_search
  :has_external_dependencies:
@@ -738,7 +759,8 @@
  :resource_boundary: :unknown
  :weight: 1
  :idempotent:
-  :tags: []
+  :tags:
+  - :exclude_from_kubernetes
 - :name: elastic_commit_indexer
  :feature_category: :global_search
  :has_external_dependencies:
@@ -802,7 +824,8 @@
  :resource_boundary: :unknown
  :weight: 1
  :idempotent: true
-  :tags: []
+  :tags:
+  - :exclude_from_kubernetes
 - :name: group_wikis_git_garbage_collect
  :feature_category: :gitaly
  :has_external_dependencies:
@@ -810,7 +833,8 @@
  :resource_boundary: :unknown
  :weight: 1
  :idempotent:
-  :tags: []
+  :tags:
+  - :exclude_from_kubernetes
 - :name: groups_schedule_bulk_repository_shard_moves
  :feature_category: :gitaly
  :has_external_dependencies:
@@ -834,7 +858,8 @@
  :resource_boundary: :unknown
  :weight: 1
  :idempotent: true
-  :tags: []
+  :tags:
+  - :exclude_from_kubernetes
 - :name: incident_management_apply_incident_sla_exceeded_label
  :feature_category: :incident_management
  :has_external_dependencies:
@@ -842,7 +867,8 @@
  :resource_boundary: :unknown
  :weight: 1
  :idempotent: true
-  :tags: []
+  :tags:
+  - :exclude_from_kubernetes
 - :name: incident_management_oncall_rotations_persist_shifts_job
  :feature_category: :incident_management
  :has_external_dependencies:
@@ -850,7 +876,8 @@
  :resource_boundary: :unknown
  :weight: 1
  :idempotent: true
-  :tags: []
+  :tags:
+  - :exclude_from_kubernetes
 - :name: ldap_group_sync
  :feature_category: :authentication_and_authorization
  :has_external_dependencies: true
@@ -898,7 +925,8 @@
  :resource_boundary: :unknown
  :weight: 1
  :idempotent:
-  :tags: []
+  :tags:
+  - :exclude_from_kubernetes
 - :name: refresh_license_compliance_checks
  :feature_category: :license_compliance
  :has_external_dependencies:
@@ -930,7 +958,8 @@
  :resource_boundary: :unknown
  :weight: 1
  :idempotent: true
-  :tags: []
+  :tags:
+  - :exclude_from_kubernetes
 - :name: requirements_management_process_requirements_reports
  :feature_category: :requirements_management
  :has_external_dependencies:
@@ -946,7 +975,8 @@
  :resource_boundary: :unknown
  :weight: 1
  :idempotent: true
-  :tags: []
+  :tags:
+  - :exclude_from_kubernetes
 - :name: set_user_status_based_on_user_cap_setting
  :feature_category: :users
  :has_external_dependencies:
@@ -954,7 +984,8 @@
  :resource_boundary: :unknown
  :weight: 1
  :idempotent: true
-  :tags: []
+  :tags:
+  - :exclude_from_kubernetes
 - :name: status_page_publish
  :feature_category: :incident_management
  :has_external_dependencies: true

--- a/ee/app/workers/analytics/devops_adoption/create_all_snapshots_worker.rb
+++ b/ee/app/workers/analytics/devops_adoption/create_all_snapshots_worker.rb
@@ -9,6 +9,7 @@ module Analytics
      include CronjobQueue # rubocop:disable Scalability/CronWorkerContext

      feature_category :devops_reports
+      tags :exclude_from_kubernetes
      idempotent!

      WORKERS_GAP = 5.seconds

--- a/ee/app/workers/analytics/devops_adoption/create_snapshot_worker.rb
+++ b/ee/app/workers/analytics/devops_adoption/create_snapshot_worker.rb
@@ -9,6 +9,7 @@ module Analytics

      feature_category :devops_reports
      idempotent!
+      tags :exclude_from_kubernetes

      # range_end was deprecated and must be removed in 14.0
      #

--- a/ee/app/workers/approval_rules/external_approval_rule_payload_worker.rb
+++ b/ee/app/workers/approval_rules/external_approval_rule_payload_worker.rb
@@ -6,6 +6,7 @@ module ApprovalRules
    idempotent!

    feature_category :source_code_management
+    tags :exclude_from_kubernetes

    def perform(rule_id, data)
      rule = ApprovalRules::ExternalApprovalRule.find(rule_id)

--- a/ee/app/workers/dast_site_validation_worker.rb
+++ b/ee/app/workers/dast_site_validation_worker.rb
@@ -10,6 +10,7 @@ class DastSiteValidationWorker
  sidekiq_retry_in { 25 }

  feature_category :dynamic_application_security_testing
+  tags :exclude_from_kubernetes

  sidekiq_retries_exhausted do |job|
    dast_site_validation = DastSiteValidation.find(job['args'][0])

--- a/ee/app/workers/deployments/auto_rollback_worker.rb
+++ b/ee/app/workers/deployments/auto_rollback_worker.rb
@@ -6,6 +6,7 @@ module Deployments

    idempotent!
    feature_category :continuous_delivery
+    tags :exclude_from_kubernetes
    queue_namespace :deployment

    def perform(environment_id)

--- a/ee/app/workers/dora/daily_metrics/refresh_worker.rb
+++ b/ee/app/workers/dora/daily_metrics/refresh_worker.rb
@@ -9,6 +9,7 @@ module Dora
      idempotent!
      queue_namespace :dora_metrics
      feature_category :continuous_delivery
+      tags :exclude_from_kubernetes

      def perform(environment_id, date)
        Environment.find_by_id(environment_id).try do |environment|

--- a/ee/app/workers/elastic_association_indexer_worker.rb
+++ b/ee/app/workers/elastic_association_indexer_worker.rb
@@ -4,6 +4,7 @@ class ElasticAssociationIndexerWorker # rubocop:disable Scalability/IdempotentWo
  include ApplicationWorker

  feature_category :global_search
+  tags :exclude_from_kubernetes
  loggable_arguments 0, 2

  def perform(class_name, id, indexed_associations)

--- a/ee/app/workers/elastic_remove_expired_namespace_subscriptions_from_index_cron_worker.rb
+++ b/ee/app/workers/elastic_remove_expired_namespace_subscriptions_from_index_cron_worker.rb
@@ -6,6 +6,7 @@ class ElasticRemoveExpiredNamespaceSubscriptionsFromIndexCronWorker
  include CronjobQueue

  feature_category :global_search
+  tags :exclude_from_kubernetes
  idempotent!

  def perform

--- a/ee/app/workers/geo/destroy_worker.rb
+++ b/ee/app/workers/geo/destroy_worker.rb
@@ -8,6 +8,7 @@ module Geo

    idempotent!

+    tags :exclude_from_kubernetes
    loggable_arguments 0

    def perform(replicable_name, replicable_id)

--- a/ee/app/workers/geo/reverification_batch_worker.rb
+++ b/ee/app/workers/geo/reverification_batch_worker.rb
@@ -13,6 +13,7 @@ module Geo
    MAX_RUNNING_JOBS = 1

    idempotent!
+    tags :exclude_from_kubernetes
    loggable_arguments 0

    def perform_work(replicable_name)

--- a/ee/app/workers/geo/secondary_usage_data_cron_worker.rb
+++ b/ee/app/workers/geo/secondary_usage_data_cron_worker.rb
@@ -10,6 +10,7 @@ module Geo
    include ExclusiveLeaseGuard

    feature_category :geo_replication
+    tags :exclude_from_kubernetes

    def perform
      return unless Gitlab::Geo.secondary?

--- a/ee/app/workers/geo/sync_timeout_cron_worker.rb
+++ b/ee/app/workers/geo/sync_timeout_cron_worker.rb
@@ -12,6 +12,7 @@ module Geo
    idempotent!
    sidekiq_options retry: false, dead: false
    feature_category :geo_replication
+    tags :exclude_from_kubernetes

    def perform
      Gitlab::Geo.enabled_replicator_classes.each do |replicator_class|

--- a/ee/app/workers/geo/verification_batch_worker.rb
+++ b/ee/app/workers/geo/verification_batch_worker.rb
@@ -8,6 +8,7 @@ module Geo
    include ::Gitlab::Geo::LogHelpers

    idempotent!
+    tags :exclude_from_kubernetes
    loggable_arguments 0

    def perform_work(replicable_name)

--- a/ee/app/workers/geo/verification_cron_worker.rb
+++ b/ee/app/workers/geo/verification_cron_worker.rb
@@ -14,6 +14,7 @@ module Geo
    idempotent!

    feature_category :geo_replication
+    tags :exclude_from_kubernetes

    def perform
      Gitlab::Geo.verification_enabled_replicator_classes.each do |replicator_class|

--- a/ee/app/workers/geo/verification_timeout_worker.rb
+++ b/ee/app/workers/geo/verification_timeout_worker.rb
@@ -9,6 +9,7 @@ module Geo

    idempotent!
    sidekiq_options retry: false, dead: false
+    tags :exclude_from_kubernetes
    loggable_arguments 0

    def perform(replicable_name)

--- a/ee/app/workers/geo/verification_worker.rb
+++ b/ee/app/workers/geo/verification_worker.rb
@@ -9,6 +9,7 @@ module Geo
    sidekiq_options retry: 3, dead: false

    idempotent!
+    tags :exclude_from_kubernetes
    loggable_arguments 0

    def perform(replicable_name, replicable_id)

--- a/ee/app/workers/group_saml_group_sync_worker.rb
+++ b/ee/app/workers/group_saml_group_sync_worker.rb
@@ -5,6 +5,7 @@ class GroupSamlGroupSyncWorker
  include Gitlab::Utils::StrongMemoize

  feature_category :authentication_and_authorization
+  tags :exclude_from_kubernetes
  idempotent!

  loggable_arguments 2

--- a/ee/app/workers/group_wikis/git_garbage_collect_worker.rb
+++ b/ee/app/workers/group_wikis/git_garbage_collect_worker.rb
@@ -5,6 +5,8 @@ module GroupWikis
    extend ::Gitlab::Utils::Override
    include GitGarbageCollectMethods

+    tags :exclude_from_kubernetes
+
    private

    override :find_resource

--- a/ee/app/workers/groups/update_statistics_worker.rb
+++ b/ee/app/workers/groups/update_statistics_worker.rb
@@ -6,6 +6,7 @@ module Groups
    include ApplicationWorker

    feature_category :source_code_management
+    tags :exclude_from_kubernetes
    idempotent!
    loggable_arguments 0, 1


--- a/ee/app/workers/incident_management/apply_incident_sla_exceeded_label_worker.rb
+++ b/ee/app/workers/incident_management/apply_incident_sla_exceeded_label_worker.rb
--- a/ee/app/workers/incident_management/incident_sla_exceeded_check_worker.rb
+++ b/ee/app/workers/incident_management/incident_sla_exceeded_check_worker.rb
--- a/ee/app/workers/incident_management/oncall_rotations/persist_all_rotations_shifts_job.rb
+++ b/ee/app/workers/incident_management/oncall_rotations/persist_all_rotations_shifts_job.rb
--- a/ee/app/workers/incident_management/oncall_rotations/persist_shifts_job.rb
+++ b/ee/app/workers/incident_management/oncall_rotations/persist_shifts_job.rb
--- a/ee/app/workers/project_template_export_worker.rb
+++ b/ee/app/workers/project_template_export_worker.rb
--- a/ee/app/workers/requirements_management/import_requirements_csv_worker.rb
+++ b/ee/app/workers/requirements_management/import_requirements_csv_worker.rb
--- a/ee/app/workers/security/auto_fix_worker.rb
+++ b/ee/app/workers/security/auto_fix_worker.rb
--- a/ee/app/workers/security/store_scans_worker.rb
+++ b/ee/app/workers/security/store_scans_worker.rb
--- a/ee/app/workers/set_user_status_based_on_user_cap_setting_worker.rb
+++ b/ee/app/workers/set_user_status_based_on_user_cap_setting_worker.rb
--- a/ee/app/workers/todos_destroyer/confidential_epic_worker.rb
+++ b/ee/app/workers/todos_destroyer/confidential_epic_worker.rb
--- a/ee/app/workers/vulnerabilities/historical_statistics/deletion_worker.rb
+++ b/ee/app/workers/vulnerabilities/historical_statistics/deletion_worker.rb