Commit 149e44d5 authored by Dylan Griffith's avatar Dylan Griffith

Merge branch 'add-tags-for-sidekiq-workers-not-on-k8s' into 'master'

Add exclude_from_kubernetes tag to workers we run on VMs [RUN AS-IF-FOSS]

See merge request gitlab-org/gitlab!60520
parents a6527ff6 abe0b763
This diff is collapsed.
......@@ -10,6 +10,7 @@ module Analytics
include CronjobQueue # rubocop:disable Scalability/CronWorkerContext
feature_category :devops_reports
tags :exclude_from_kubernetes
urgency :low
idempotent!
......
......@@ -10,6 +10,7 @@ module Analytics
feature_category :devops_reports
urgency :low
tags :exclude_from_kubernetes
idempotent!
......
......@@ -12,6 +12,7 @@ module Analytics
DEFAULT_DELAY = 3.minutes.freeze
feature_category :devops_reports
tags :exclude_from_kubernetes
urgency :low
idempotent!
......
......@@ -10,6 +10,7 @@ module Analytics
feature_category :devops_reports
urgency :low
tags :exclude_from_kubernetes
idempotent!
......
......@@ -8,6 +8,7 @@ class ApproveBlockedPendingApprovalUsersWorker
idempotent!
feature_category :users
tags :exclude_from_kubernetes
def perform(current_user_id)
current_user = User.find(current_user_id)
......
......@@ -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
......
......@@ -5,6 +5,7 @@ module BulkImports
include ApplicationWorker
feature_category :importers
tags :exclude_from_kubernetes
sidekiq_options retry: false, dead: false
......
......@@ -5,6 +5,7 @@ module BulkImports
include ApplicationWorker
feature_category :importers
tags :exclude_from_kubernetes
sidekiq_options retry: false, dead: false
......
......@@ -8,6 +8,7 @@ module Ci
include LimitedCapacity::Worker
feature_category :continuous_integration
tags :exclude_from_kubernetes
idempotent!
def perform_work(*args)
......
......@@ -7,6 +7,8 @@ module Ci
sidekiq_options retry: 3
include PipelineQueue
tags :exclude_from_kubernetes
idempotent!
def perform(pipeline_id, failure_reason)
......
......@@ -8,6 +8,7 @@ module Ci
include PipelineQueue
urgency :low
tags :exclude_from_kubernetes
idempotent!
def perform(job_id)
......
......@@ -9,6 +9,7 @@ module Ci
include PipelineBackgroundQueue
feature_category :code_testing
tags :exclude_from_kubernetes
idempotent!
......
......@@ -9,6 +9,7 @@ module Ci
queue_namespace :pipeline_background
feature_category :code_testing
tags :exclude_from_kubernetes
idempotent!
......
......@@ -14,6 +14,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
......
......@@ -11,6 +11,7 @@ module Ci
# rubocop:enable Scalability/CronWorkerContext
feature_category :continuous_integration
tags :exclude_from_kubernetes
idempotent!
def perform(*args)
......
......@@ -7,6 +7,8 @@ module Ci
sidekiq_options retry: 3
include PipelineBackgroundQueue
tags :exclude_from_kubernetes
idempotent!
def perform(pipeline_id)
......
......@@ -10,6 +10,7 @@ module ContainerExpirationPolicies
queue_namespace :container_repository
feature_category :container_registry
tags :exclude_from_kubernetes
urgency :low
worker_resource_boundary :unknown
idempotent!
......
......@@ -8,6 +8,7 @@ module Database
include CronjobQueue # rubocop:disable Scalability/CronWorkerContext
feature_category :database
tags :exclude_from_kubernetes
idempotent!
LEASE_TIMEOUT_MULTIPLIER = 3
......
......@@ -8,6 +8,7 @@ module Deployments
queue_namespace :deployment
feature_category :continuous_delivery
tags :exclude_from_kubernetes
def perform(deployment_id)
Deployments::OlderDeploymentsDropService.new(deployment_id).execute
......
......@@ -7,6 +7,7 @@ module DesignManagement
sidekiq_options retry: 3
feature_category :design_management
tags :exclude_from_kubernetes
idempotent!
urgency :low
......
......@@ -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)
......
......@@ -7,6 +7,7 @@ class DisallowTwoFactorForGroupWorker
include ExceptionBacktrace
feature_category :subgroups
tags :exclude_from_kubernetes
idempotent!
def perform(group_id)
......
......@@ -9,6 +9,7 @@ class DisallowTwoFactorForSubgroupsWorker
INTERVAL = 2.seconds.to_i
feature_category :subgroups
tags :exclude_from_kubernetes
idempotent!
def perform(group_id)
......
......@@ -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|
......
......@@ -7,6 +7,7 @@ module Experiments
sidekiq_options retry: 3
feature_category :users
tags :exclude_from_kubernetes
urgency :low
idempotent!
......
......@@ -11,6 +11,7 @@ class FlushCounterIncrementsWorker
sidekiq_options retry: 3
feature_category_not_owned!
tags :exclude_from_kubernetes
urgency :low
deduplicate :until_executing, including_scheduled: true
......
......@@ -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
......
......@@ -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
......
......@@ -10,6 +10,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)
......
......@@ -10,6 +10,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)
......
......@@ -12,6 +12,7 @@ class GitlabPerformanceBarStatsWorker
STATS_KEY_EXPIRE = 30.minutes.to_i
feature_category :metrics
tags :exclude_from_kubernetes
idempotent!
def perform(lease_uuid)
......
......@@ -7,7 +7,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
......
......@@ -8,6 +8,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?
......
......@@ -8,6 +8,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?
......
......@@ -11,6 +11,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)
......
......@@ -11,6 +11,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)
......
......@@ -11,6 +11,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)
......
......@@ -8,6 +8,7 @@ module JiraConnect
queue_namespace :jira_connect
feature_category :integrations
tags :exclude_from_kubernetes
idempotent!
worker_has_external_dependencies!
......
......@@ -7,6 +7,7 @@ class MemberInvitationReminderEmailsWorker # rubocop:disable Scalability/Idempot
include CronjobQueue # rubocop:disable Scalability/CronWorkerContext
feature_category :subgroups
tags :exclude_from_kubernetes
urgency :low
def perform
......
......@@ -6,6 +6,7 @@ class MergeRequestCleanupRefsWorker
sidekiq_options retry: 3
feature_category :code_review
tags :exclude_from_kubernetes
idempotent!
def perform(merge_request_id)
......
......@@ -8,6 +8,7 @@ module Metrics
sidekiq_options retry: 3
feature_category :metrics
tags :exclude_from_kubernetes
idempotent!
......
......@@ -8,6 +8,7 @@ module Namespaces
include CronjobQueue # rubocop:disable Scalability/CronWorkerContext
feature_category :subgroups
tags :exclude_from_kubernetes
urgency :low
def perform
......
......@@ -7,6 +7,7 @@ module Namespaces
sidekiq_options retry: 3
feature_category :issue_tracking
tags :exclude_from_kubernetes
urgency :low
deduplicate :until_executing
......
......@@ -7,6 +7,7 @@ module Namespaces
sidekiq_options retry: 3
feature_category :subgroups
tags :exclude_from_kubernetes
urgency :low
deduplicate :until_executing
......
......@@ -7,6 +7,7 @@ module Namespaces
sidekiq_options retry: 3
feature_category :product_analytics
tags :exclude_from_kubernetes
urgency :low
deduplicate :until_executed
......
......@@ -7,6 +7,7 @@ module Namespaces
sidekiq_options retry: 3
feature_category :users
tags :exclude_from_kubernetes
urgency :low
idempotent!
......
......@@ -9,6 +9,7 @@ module Packages
include CronjobQueue # rubocop:disable Scalability/CronWorkerContext
feature_category :package_registry
tags :exclude_from_kubernetes
idempotent!
......
......@@ -8,6 +8,7 @@ module Packages
sidekiq_options retry: 3
feature_category :package_registry
tags :exclude_from_kubernetes
idempotent!
......
......@@ -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
......
......@@ -10,6 +10,7 @@ module Packages
queue_namespace :package_repositories
feature_category :package_registry
tags :exclude_from_kubernetes
deduplicate :until_executing
idempotent!
......
......@@ -11,6 +11,7 @@ module Packages
queue_namespace :package_repositories
feature_category :package_registry
tags :exclude_from_kubernetes
deduplicate :until_executing
idempotent!
......
......@@ -9,6 +9,7 @@ module Packages
queue_namespace :package_repositories
feature_category :package_registry
tags :exclude_from_kubernetes
deduplicate :until_executing
idempotent!
......
......@@ -6,7 +6,7 @@ class PagesDomainSslRenewalWorker # rubocop:disable Scalability/IdempotentWorker
sidekiq_options retry: 3
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)
......
......@@ -6,7 +6,7 @@ class PagesDomainVerificationWorker # rubocop:disable Scalability/IdempotentWork
sidekiq_options retry: 3
feature_category :pages
tags :requires_disk_io
tags :requires_disk_io, :exclude_from_kubernetes
# rubocop: disable CodeReuse/ActiveRecord
def perform(domain_id)
......
......@@ -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)
......
......@@ -8,6 +8,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)
......
......@@ -7,6 +7,7 @@ class PagesUpdateConfigurationWorker
idempotent!
feature_category :pages
tags :exclude_from_kubernetes
def self.perform_async(*args)
return unless ::Settings.pages.local_store.enabled
......
......@@ -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
......
......@@ -8,6 +8,7 @@ module PersonalAccessTokens
include CronjobQueue
feature_category :authentication_and_authorization
tags :exclude_from_kubernetes
def perform(*args)
notification_service = NotificationService.new
......
......@@ -7,7 +7,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)
......
......@@ -5,6 +5,8 @@ module Projects
extend ::Gitlab::Utils::Override
include GitGarbageCollectMethods
tags :exclude_from_kubernetes
private
override :find_resource
......
......@@ -7,6 +7,7 @@ module Projects
sidekiq_options retry: 3
feature_category :source_code_management
tags :exclude_from_kubernetes
idempotent!
def perform(project_id)
......
......@@ -6,6 +6,7 @@ class PropagateIntegrationGroupWorker
sidekiq_options retry: 3
feature_category :integrations
tags :exclude_from_kubernetes
idempotent!
# rubocop: disable CodeReuse/ActiveRecord
......
......@@ -6,6 +6,7 @@ class PropagateIntegrationInheritDescendantWorker
sidekiq_options retry: 3
feature_category :integrations
tags :exclude_from_kubernetes
idempotent!
# rubocop: disable CodeReuse/ActiveRecord
......
......@@ -6,6 +6,7 @@ class PropagateIntegrationInheritWorker
sidekiq_options retry: 3
feature_category :integrations
tags :exclude_from_kubernetes
idempotent!
# rubocop: disable CodeReuse/ActiveRecord
......
......@@ -6,6 +6,7 @@ class PropagateIntegrationProjectWorker
sidekiq_options retry: 3
feature_category :integrations
tags :exclude_from_kubernetes
idempotent!
# rubocop: disable CodeReuse/ActiveRecord
......
......@@ -7,6 +7,7 @@ module Releases
sidekiq_options retry: 3
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
......
......@@ -8,6 +8,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
......
......@@ -7,6 +7,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!
......
......@@ -7,6 +7,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
......
......@@ -8,6 +8,7 @@ module SshKeys
include CronjobQueue
feature_category :compliance_management
tags :exclude_from_kubernetes
idempotent!
def perform
......
......@@ -8,6 +8,7 @@ module SshKeys
include CronjobQueue
feature_category :compliance_management
tags :exclude_from_kubernetes
idempotent!
def perform
......
......@@ -7,6 +7,8 @@ module TodosDestroyer
sidekiq_options retry: 3
include TodosDestroyerQueue
tags :exclude_from_kubernetes
idempotent!
def perform(target_id, target_type)
......
......@@ -11,6 +11,7 @@ module UserStatusCleanup
# rubocop:enable Scalability/CronWorkerContext
feature_category :users
tags :exclude_from_kubernetes
idempotent!
......
......@@ -7,6 +7,7 @@ module Users
include CronjobQueue
feature_category :utilization
tags :exclude_from_kubernetes
NUMBER_OF_BATCHES = 50
BATCH_SIZE = 200
......
......@@ -5,6 +5,7 @@ module Users
include ApplicationWorker
feature_category :users
tags :exclude_from_kubernetes
idempotent!
def perform(target_user_ids)
......
......@@ -7,6 +7,7 @@ module WebHooks
sidekiq_options retry: 3
feature_category :integrations
tags :exclude_from_kubernetes
urgency :low
idempotent!
......
......@@ -5,6 +5,8 @@ module Wikis
extend ::Gitlab::Utils::Override
include GitGarbageCollectMethods
tags :exclude_from_kubernetes
private
override :find_resource
......
......@@ -10,6 +10,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|
......
......@@ -20,7 +20,8 @@
:resource_boundary: :unknown
:weight: 1
:idempotent:
:tags: []
:tags:
- :exclude_from_kubernetes
- :name: cronjob:adjourned_group_deletion
:worker_name: AdjournedGroupDeletionWorker
:feature_category: :authentication_and_authorization
......@@ -47,7 +48,8 @@
:resource_boundary: :unknown
:weight: 1
:idempotent: true
:tags: []
:tags:
- :exclude_from_kubernetes
- :name: cronjob:clear_shared_runners_minutes
:worker_name: ClearSharedRunnersMinutesWorker
:feature_category: :continuous_integration
......@@ -101,7 +103,8 @@
:resource_boundary: :unknown
:weight: 1
:idempotent: true
:tags: []
:tags:
- :exclude_from_kubernetes
- :name: cronjob:geo_container_repository_sync_dispatch
:worker_name: Geo::ContainerRepositorySyncDispatchWorker
:feature_category: :geo_replication
......@@ -227,7 +230,8 @@
:resource_boundary: :unknown
:weight: 1
:idempotent:
:tags: []
:tags:
- :exclude_from_kubernetes
- :name: cronjob:geo_sidekiq_cron_config
:worker_name: Geo::SidekiqCronConfigWorker
:feature_category: :geo_replication
......@@ -245,7 +249,8 @@
:resource_boundary: :unknown
:weight: 1
:idempotent: true
:tags: []
:tags:
- :exclude_from_kubernetes
- :name: cronjob:geo_verification_cron
:worker_name: Geo::VerificationCronWorker
:feature_category: :geo_replication
......@@ -254,7 +259,8 @@
:resource_boundary: :unknown
:weight: 1
:idempotent: true
:tags: []
:tags:
- :exclude_from_kubernetes
- :name: cronjob:historical_data
:worker_name: HistoricalDataWorker
:feature_category: :utilization
......@@ -281,7 +287,8 @@
:resource_boundary: :unknown
:weight: 1
:idempotent: true
:tags: []
:tags:
- :exclude_from_kubernetes
- :name: cronjob:incident_management_oncall_rotations_persist_all_rotations_shifts_job
:worker_name: IncidentManagement::OncallRotations::PersistAllRotationsShiftsJob
:feature_category: :incident_management
......@@ -290,7 +297,8 @@
:resource_boundary: :unknown
:weight: 1
:idempotent: true
:tags: []
:tags:
- :exclude_from_kubernetes
- :name: cronjob:ingress_modsecurity_counter_metrics
:worker_name: IngressModsecurityCounterMetricsWorker
:feature_category: :web_firewall
......@@ -380,7 +388,8 @@
:resource_boundary: :unknown
:weight: 1
:idempotent:
:tags: []
:tags:
- :exclude_from_kubernetes
- :name: cronjob:vulnerabilities_statistics_schedule
:worker_name: Vulnerabilities::Statistics::ScheduleWorker
:feature_category: :vulnerability_management
......@@ -398,7 +407,8 @@
:resource_boundary: :unknown
:weight: 3
:idempotent: true
:tags: []
:tags:
- :exclude_from_kubernetes
- :name: dora_metrics:dora_daily_metrics_refresh
:worker_name: Dora::DailyMetrics::RefreshWorker
:feature_category: :continuous_delivery
......@@ -407,7 +417,8 @@
:resource_boundary: :unknown
:weight: 1
:idempotent: true
:tags: []
:tags:
- :exclude_from_kubernetes
- :name: epics:epics_update_epics_dates
:worker_name: Epics::UpdateEpicsDatesWorker
:feature_category: :epics
......@@ -470,7 +481,8 @@
:resource_boundary: :unknown
:weight: 1
:idempotent: true
:tags: []
:tags:
- :exclude_from_kubernetes
- :name: geo:geo_event
:worker_name: Geo::EventWorker
:feature_category: :geo_replication
......@@ -614,7 +626,8 @@
:resource_boundary: :unknown
:weight: 1
:idempotent: true
:tags: []
:tags:
- :exclude_from_kubernetes
- :name: geo:geo_scheduler_primary_scheduler
:worker_name: Geo::Scheduler::Primary::SchedulerWorker
:feature_category: :geo_replication
......@@ -650,7 +663,8 @@
:resource_boundary: :unknown
:weight: 1
:idempotent: true
:tags: []
:tags:
- :exclude_from_kubernetes
- :name: geo:geo_verification_batch
:worker_name: Geo::VerificationBatchWorker
:feature_category: :geo_replication
......@@ -659,7 +673,8 @@
:resource_boundary: :unknown
:weight: 1
:idempotent: true
:tags: []
:tags:
- :exclude_from_kubernetes
- :name: geo:geo_verification_timeout
:worker_name: Geo::VerificationTimeoutWorker
:feature_category: :geo_replication
......@@ -668,7 +683,8 @@
:resource_boundary: :unknown
:weight: 1
:idempotent: true
:tags: []
:tags:
- :exclude_from_kubernetes
- :name: personal_access_tokens:personal_access_tokens_groups_policy
:worker_name: PersonalAccessTokens::Groups::PolicyWorker
:feature_category: :authentication_and_authorization
......@@ -713,7 +729,8 @@
:resource_boundary: :unknown
:weight: 2
:idempotent:
:tags: []
:tags:
- :exclude_from_kubernetes
- :name: security_scans:store_security_reports
:worker_name: StoreSecurityReportsWorker
:feature_category: :static_application_security_testing
......@@ -749,7 +766,8 @@
:resource_boundary: :unknown
:weight: 1
:idempotent:
:tags: []
:tags:
- :exclude_from_kubernetes
- :name: adjourned_project_deletion
:worker_name: AdjournedProjectDeletionWorker
:feature_category: :authentication_and_authorization
......@@ -785,7 +803,8 @@
:resource_boundary: :unknown
:weight: 1
:idempotent: true
:tags: []
:tags:
- :exclude_from_kubernetes
- :name: approval_rules_external_approval_rule_payload
:worker_name: ApprovalRules::ExternalApprovalRulePayloadWorker
:feature_category: :source_code_management
......@@ -794,7 +813,8 @@
:resource_boundary: :unknown
:weight: 1
:idempotent: true
:tags: []
:tags:
- :exclude_from_kubernetes
- :name: ci_batch_reset_minutes
:worker_name: Ci::BatchResetMinutesWorker
:feature_category: :continuous_integration
......@@ -821,7 +841,8 @@
:resource_boundary: :unknown
:weight: 1
:idempotent: true
:tags: []
:tags:
- :exclude_from_kubernetes
- :name: elastic_association_indexer
:worker_name: ElasticAssociationIndexerWorker
:feature_category: :global_search
......@@ -830,7 +851,8 @@
:resource_boundary: :unknown
:weight: 1
:idempotent:
:tags: []
:tags:
- :exclude_from_kubernetes
- :name: elastic_commit_indexer
:worker_name: ElasticCommitIndexerWorker
:feature_category: :global_search
......@@ -902,7 +924,8 @@
:resource_boundary: :unknown
:weight: 1
:idempotent: true
:tags: []
:tags:
- :exclude_from_kubernetes
- :name: group_wikis_git_garbage_collect
:worker_name: GroupWikis::GitGarbageCollectWorker
:feature_category: :gitaly
......@@ -911,7 +934,8 @@
:resource_boundary: :unknown
:weight: 1
:idempotent:
:tags: []
:tags:
- :exclude_from_kubernetes
- :name: groups_schedule_bulk_repository_shard_moves
:worker_name: Groups::ScheduleBulkRepositoryShardMovesWorker
:feature_category: :gitaly
......@@ -938,7 +962,8 @@
:resource_boundary: :unknown
:weight: 1
:idempotent: true
:tags: []
:tags:
- :exclude_from_kubernetes
- :name: incident_management_apply_incident_sla_exceeded_label
:worker_name: IncidentManagement::ApplyIncidentSlaExceededLabelWorker
:feature_category: :incident_management
......@@ -947,7 +972,8 @@
:resource_boundary: :unknown
:weight: 1
:idempotent: true
:tags: []
:tags:
- :exclude_from_kubernetes
- :name: incident_management_oncall_rotations_persist_shifts_job
:worker_name: IncidentManagement::OncallRotations::PersistShiftsJob
:feature_category: :incident_management
......@@ -956,7 +982,8 @@
:resource_boundary: :unknown
:weight: 1
:idempotent: true
:tags: []
:tags:
- :exclude_from_kubernetes
- :name: ldap_group_sync
:worker_name: LdapGroupSyncWorker
:feature_category: :authentication_and_authorization
......@@ -1010,7 +1037,8 @@
:resource_boundary: :unknown
:weight: 1
:idempotent:
:tags: []
:tags:
- :exclude_from_kubernetes
- :name: refresh_license_compliance_checks
:worker_name: RefreshLicenseComplianceChecksWorker
:feature_category: :license_compliance
......@@ -1046,7 +1074,8 @@
:resource_boundary: :unknown
:weight: 1
:idempotent: true
:tags: []
:tags:
- :exclude_from_kubernetes
- :name: requirements_management_process_requirements_reports
:worker_name: RequirementsManagement::ProcessRequirementsReportsWorker
:feature_category: :requirements_management
......@@ -1064,7 +1093,8 @@
:resource_boundary: :unknown
:weight: 1
:idempotent: true
:tags: []
:tags:
- :exclude_from_kubernetes
- :name: set_user_status_based_on_user_cap_setting
:worker_name: SetUserStatusBasedOnUserCapSettingWorker
:feature_category: :users
......@@ -1073,7 +1103,8 @@
:resource_boundary: :unknown
:weight: 1
:idempotent: true
:tags: []
:tags:
- :exclude_from_kubernetes
- :name: status_page_publish
:worker_name: StatusPage::PublishWorker
:feature_category: :incident_management
......
......@@ -11,6 +11,7 @@ module Analytics
include CronjobQueue # rubocop:disable Scalability/CronWorkerContext
feature_category :devops_reports
tags :exclude_from_kubernetes
idempotent!
WORKERS_GAP = 5.seconds
......
......@@ -11,6 +11,7 @@ module Analytics
feature_category :devops_reports
idempotent!
tags :exclude_from_kubernetes
# range_end was deprecated and must be removed in 14.0
#
......
......@@ -8,6 +8,7 @@ module ApprovalRules
idempotent!
feature_category :source_code_management
tags :exclude_from_kubernetes
def perform(rule_id, data)
rule = ApprovalRules::ExternalApprovalRule.find(rule_id)
......
......@@ -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])
......
......@@ -8,6 +8,7 @@ module Deployments
idempotent!
feature_category :continuous_delivery
tags :exclude_from_kubernetes
queue_namespace :deployment
def perform(environment_id)
......
......@@ -11,6 +11,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|
......
......@@ -6,6 +6,7 @@ class ElasticAssociationIndexerWorker # rubocop:disable Scalability/IdempotentWo
sidekiq_options retry: 3
feature_category :global_search
tags :exclude_from_kubernetes
loggable_arguments 0, 2
def perform(class_name, id, indexed_associations)
......
......@@ -8,6 +8,7 @@ class ElasticRemoveExpiredNamespaceSubscriptionsFromIndexCronWorker
include CronjobQueue
feature_category :global_search
tags :exclude_from_kubernetes
idempotent!
def perform
......
......@@ -10,6 +10,7 @@ module Geo
idempotent!
tags :exclude_from_kubernetes
loggable_arguments 0
def perform(replicable_name, replicable_id)
......
......@@ -15,6 +15,7 @@ module Geo
MAX_RUNNING_JOBS = 1
idempotent!
tags :exclude_from_kubernetes
loggable_arguments 0
def perform_work(replicable_name)
......
......@@ -12,6 +12,7 @@ module Geo
include ExclusiveLeaseGuard
feature_category :geo_replication
tags :exclude_from_kubernetes
def perform
return unless Gitlab::Geo.secondary?
......
......@@ -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|
......
......@@ -10,6 +10,7 @@ module Geo
include ::Gitlab::Geo::LogHelpers
idempotent!
tags :exclude_from_kubernetes
loggable_arguments 0
def perform_work(replicable_name)
......
......@@ -16,6 +16,7 @@ module Geo
idempotent!
feature_category :geo_replication
tags :exclude_from_kubernetes
def perform
Gitlab::Geo.verification_enabled_replicator_classes.each do |replicator_class|
......
......@@ -9,6 +9,7 @@ module Geo
idempotent!
sidekiq_options retry: false, dead: false
tags :exclude_from_kubernetes
loggable_arguments 0
def perform(replicable_name)
......
......@@ -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)
......
......@@ -7,6 +7,7 @@ class GroupSamlGroupSyncWorker
include Gitlab::Utils::StrongMemoize
feature_category :authentication_and_authorization
tags :exclude_from_kubernetes
idempotent!
loggable_arguments 2
......
......@@ -5,6 +5,8 @@ module GroupWikis
extend ::Gitlab::Utils::Override
include GitGarbageCollectMethods
tags :exclude_from_kubernetes
private
override :find_resource
......
......@@ -8,6 +8,7 @@ module Groups
sidekiq_options retry: 3
feature_category :source_code_management
tags :exclude_from_kubernetes
idempotent!
loggable_arguments 0, 1
......
This diff is collapsed.
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