Merge branch 'add-idempotency-cop-for-workers' into 'master'

Introduce `idempotent` worker attribute with new Cop

See merge request gitlab-org/gitlab!25202

app/workers/admin_email_worker.rb

 # frozen_string_literal: true
 
-class AdminEmailWorker
+class AdminEmailWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   # rubocop:disable Scalability/CronWorkerContext
   # This worker does not perform work scoped to a context

app/workers/all_queues.yml

@@ -9,1077 +9,1257 @@
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 2
+  :idempotent: 
 - :name: auto_merge:auto_merge_process
   :feature_category: :continuous_delivery
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :cpu
   :weight: 3
+  :idempotent: 
 - :name: chaos:chaos_cpu_spin
   :feature_category: :chaos_engineering
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 2
+  :idempotent: 
 - :name: chaos:chaos_db_spin
   :feature_category: :chaos_engineering
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 2
+  :idempotent: 
 - :name: chaos:chaos_kill
   :feature_category: :chaos_engineering
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 2
+  :idempotent: 
 - :name: chaos:chaos_leak_mem
   :feature_category: :chaos_engineering
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 2
+  :idempotent: 
 - :name: chaos:chaos_sleep
   :feature_category: :chaos_engineering
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 2
+  :idempotent: 
 - :name: container_repository:cleanup_container_repository
   :feature_category: :container_registry
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: container_repository:delete_container_repository
   :feature_category: :container_registry
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: cronjob:admin_email
   :feature_category: :source_code_management
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: cronjob:ci_archive_traces_cron
   :feature_category: :continuous_integration
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: cronjob:container_expiration_policy
   :feature_category: :container_registry
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: cronjob:environments_auto_stop_cron
   :feature_category: :continuous_delivery
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: cronjob:expire_build_artifacts
   :feature_category: :continuous_integration
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: cronjob:gitlab_usage_ping
   :feature_category: :collection
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: cronjob:import_export_project_cleanup
   :feature_category: :importers
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: cronjob:issue_due_scheduler
   :feature_category: :issue_tracking
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: cronjob:namespaces_prune_aggregation_schedules
   :feature_category: :source_code_management
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :cpu
   :weight: 1
+  :idempotent: 
 - :name: cronjob:pages_domain_removal_cron
   :feature_category: :pages
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :cpu
   :weight: 1
+  :idempotent: 
 - :name: cronjob:pages_domain_ssl_renewal_cron
   :feature_category: :pages
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: cronjob:pages_domain_verification_cron
   :feature_category: :pages
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: cronjob:personal_access_tokens_expiring
   :feature_category: :authentication_and_authorization
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: cronjob:pipeline_schedule
   :feature_category: :continuous_integration
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :cpu
   :weight: 1
+  :idempotent: 
 - :name: cronjob:prune_old_events
   :feature_category: :users
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: cronjob:prune_web_hook_logs
   :feature_category: :integrations
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: cronjob:remove_expired_group_links
   :feature_category: :authentication_and_authorization
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: cronjob:remove_expired_members
   :feature_category: :authentication_and_authorization
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :cpu
   :weight: 1
+  :idempotent: 
 - :name: cronjob:remove_unreferenced_lfs_objects
   :feature_category: :git_lfs
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: cronjob:repository_archive_cache
   :feature_category: :source_code_management
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: cronjob:repository_check_dispatch
   :feature_category: :source_code_management
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: cronjob:requests_profiles
   :feature_category: :source_code_management
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: cronjob:schedule_migrate_external_diffs
   :feature_category: :source_code_management
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: cronjob:stuck_ci_jobs
   :feature_category: :continuous_integration
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :cpu
   :weight: 1
+  :idempotent: 
 - :name: cronjob:stuck_import_jobs
   :feature_category: :importers
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :cpu
   :weight: 1
+  :idempotent: 
 - :name: cronjob:stuck_merge_jobs
   :feature_category: :source_code_management
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: cronjob:trending_projects
   :feature_category: :source_code_management
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: deployment:deployments_finished
   :feature_category: :continuous_delivery
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :cpu
   :weight: 3
+  :idempotent: 
 - :name: deployment:deployments_forward_deployment
   :feature_category: :continuous_delivery
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 3
+  :idempotent: 
 - :name: deployment:deployments_success
   :feature_category: :continuous_delivery
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :cpu
   :weight: 3
+  :idempotent: 
 - :name: gcp_cluster:cluster_configure
   :feature_category: :kubernetes_management
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: gcp_cluster:cluster_configure_istio
   :feature_category: :kubernetes_management
   :has_external_dependencies: true
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: gcp_cluster:cluster_install_app
   :feature_category: :kubernetes_management
   :has_external_dependencies: true
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: gcp_cluster:cluster_patch_app
   :feature_category: :kubernetes_management
   :has_external_dependencies: true
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: gcp_cluster:cluster_project_configure
   :feature_category: :kubernetes_management
   :has_external_dependencies: true
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: gcp_cluster:cluster_provision
   :feature_category: :kubernetes_management
   :has_external_dependencies: true
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: gcp_cluster:cluster_upgrade_app
   :feature_category: :kubernetes_management
   :has_external_dependencies: true
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: gcp_cluster:cluster_wait_for_app_installation
   :feature_category: :kubernetes_management
   :has_external_dependencies: true
   :latency_sensitive: 
   :resource_boundary: :cpu
   :weight: 1
+  :idempotent: 
 - :name: gcp_cluster:cluster_wait_for_ingress_ip_address
   :feature_category: :kubernetes_management
   :has_external_dependencies: true
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: gcp_cluster:clusters_applications_activate_service
   :feature_category: :kubernetes_management
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: gcp_cluster:clusters_applications_deactivate_service
   :feature_category: :kubernetes_management
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: gcp_cluster:clusters_applications_uninstall
   :feature_category: :kubernetes_management
   :has_external_dependencies: true
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: gcp_cluster:clusters_applications_wait_for_uninstall_app
   :feature_category: :kubernetes_management
   :has_external_dependencies: true
   :latency_sensitive: 
   :resource_boundary: :cpu
   :weight: 1
+  :idempotent: 
 - :name: gcp_cluster:clusters_cleanup_app
   :feature_category: :kubernetes_management
   :has_external_dependencies: true
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: gcp_cluster:clusters_cleanup_project_namespace
   :feature_category: :kubernetes_management
   :has_external_dependencies: true
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: gcp_cluster:clusters_cleanup_service_account
   :feature_category: :kubernetes_management
   :has_external_dependencies: true
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: gcp_cluster:wait_for_cluster_creation
   :feature_category: :kubernetes_management
   :has_external_dependencies: true
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: github_importer:github_import_import_diff_note
   :feature_category: :importers
   :has_external_dependencies: true
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: github_importer:github_import_import_issue
   :feature_category: :importers
   :has_external_dependencies: true
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: github_importer:github_import_import_lfs_object
   :feature_category: :importers
   :has_external_dependencies: true
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: github_importer:github_import_import_note
   :feature_category: :importers
   :has_external_dependencies: true
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: github_importer:github_import_import_pull_request
   :feature_category: :importers
   :has_external_dependencies: true
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: github_importer:github_import_refresh_import_jid
   :feature_category: :importers
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: github_importer:github_import_stage_finish_import
   :feature_category: :importers
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: github_importer:github_import_stage_import_base_data
   :feature_category: :importers
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: github_importer:github_import_stage_import_issues_and_diff_notes
   :feature_category: :importers
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: github_importer:github_import_stage_import_lfs_objects
   :feature_category: :importers
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: github_importer:github_import_stage_import_notes
   :feature_category: :importers
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: github_importer:github_import_stage_import_pull_requests
   :feature_category: :importers
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: github_importer:github_import_stage_import_repository
   :feature_category: :importers
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: hashed_storage:hashed_storage_migrator
   :feature_category: :source_code_management
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: hashed_storage:hashed_storage_project_migrate
   :feature_category: :source_code_management
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: hashed_storage:hashed_storage_project_rollback
   :feature_category: :source_code_management
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: hashed_storage:hashed_storage_rollbacker
   :feature_category: :source_code_management
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: incident_management:incident_management_process_alert
   :feature_category: :incident_management
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 2
+  :idempotent: 
 - :name: mail_scheduler:mail_scheduler_issue_due
   :feature_category: :issue_tracking
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 2
+  :idempotent: 
 - :name: mail_scheduler:mail_scheduler_notification_service
   :feature_category: :issue_tracking
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :cpu
   :weight: 2
+  :idempotent: 
 - :name: notifications:new_release
   :feature_category: :release_orchestration
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 2
+  :idempotent: 
 - :name: object_pool:object_pool_create
   :feature_category: :gitaly
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: object_pool:object_pool_destroy
   :feature_category: :gitaly
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: object_pool:object_pool_join
   :feature_category: :gitaly
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :cpu
   :weight: 1
+  :idempotent: 
 - :name: object_pool:object_pool_schedule_join
   :feature_category: :gitaly
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: object_storage:object_storage_background_move
   :feature_category: :not_owned
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: object_storage:object_storage_migrate_uploads
   :feature_category: :not_owned
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: pipeline_background:archive_trace
   :feature_category: :continuous_integration
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: pipeline_background:ci_build_trace_chunk_flush
   :feature_category: :continuous_integration
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: pipeline_cache:expire_job_cache
   :feature_category: :continuous_integration
   :has_external_dependencies: 
   :latency_sensitive: true
   :resource_boundary: :unknown
   :weight: 3
+  :idempotent: true
 - :name: pipeline_cache:expire_pipeline_cache
   :feature_category: :continuous_integration
   :has_external_dependencies: 
   :latency_sensitive: true
   :resource_boundary: :cpu
   :weight: 3
+  :idempotent: 
 - :name: pipeline_creation:create_pipeline
   :feature_category: :continuous_integration
   :has_external_dependencies: 
   :latency_sensitive: true
   :resource_boundary: :cpu
   :weight: 4
+  :idempotent: 
 - :name: pipeline_creation:run_pipeline_schedule
   :feature_category: :continuous_integration
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 4
+  :idempotent: 
 - :name: pipeline_default:build_coverage
   :feature_category: :continuous_integration
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 3
+  :idempotent: 
 - :name: pipeline_default:build_trace_sections
   :feature_category: :continuous_integration
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 3
+  :idempotent: 
 - :name: pipeline_default:ci_create_cross_project_pipeline
   :feature_category: :continuous_integration
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :cpu
   :weight: 3
+  :idempotent: 
 - :name: pipeline_default:ci_pipeline_bridge_status
   :feature_category: :continuous_integration
   :has_external_dependencies: 
   :latency_sensitive: true
   :resource_boundary: :cpu
   :weight: 3
+  :idempotent: 
 - :name: pipeline_default:pipeline_metrics
   :feature_category: :continuous_integration
   :has_external_dependencies: 
   :latency_sensitive: true
   :resource_boundary: :unknown
   :weight: 3
+  :idempotent: 
 - :name: pipeline_default:pipeline_notification
   :feature_category: :continuous_integration
   :has_external_dependencies: 
   :latency_sensitive: true
   :resource_boundary: :cpu
   :weight: 3
+  :idempotent: 
 - :name: pipeline_hooks:build_hooks
   :feature_category: :continuous_integration
   :has_external_dependencies: 
   :latency_sensitive: true
   :resource_boundary: :unknown
   :weight: 2
+  :idempotent: 
 - :name: pipeline_hooks:pipeline_hooks
   :feature_category: :continuous_integration
   :has_external_dependencies: 
   :latency_sensitive: true
   :resource_boundary: :cpu
   :weight: 2
+  :idempotent: 
 - :name: pipeline_processing:build_finished
   :feature_category: :continuous_integration
   :has_external_dependencies: 
   :latency_sensitive: true
   :resource_boundary: :cpu
   :weight: 5
+  :idempotent: 
 - :name: pipeline_processing:build_queue
   :feature_category: :continuous_integration
   :has_external_dependencies: 
   :latency_sensitive: true
   :resource_boundary: :cpu
   :weight: 5
+  :idempotent: 
 - :name: pipeline_processing:build_success
   :feature_category: :continuous_integration
   :has_external_dependencies: 
   :latency_sensitive: true
   :resource_boundary: :unknown
   :weight: 5
+  :idempotent: 
 - :name: pipeline_processing:ci_build_prepare
   :feature_category: :continuous_integration
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 5
+  :idempotent: 
 - :name: pipeline_processing:ci_build_schedule
   :feature_category: :continuous_integration
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :cpu
   :weight: 5
+  :idempotent: 
 - :name: pipeline_processing:ci_resource_groups_assign_resource_from_resource_group
   :feature_category: :continuous_delivery
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 5
+  :idempotent: 
 - :name: pipeline_processing:pipeline_process
   :feature_category: :continuous_integration
   :has_external_dependencies: 
   :latency_sensitive: true
   :resource_boundary: :unknown
   :weight: 5
+  :idempotent: 
 - :name: pipeline_processing:pipeline_success
   :feature_category: :continuous_integration
   :has_external_dependencies: 
   :latency_sensitive: true
   :resource_boundary: :unknown
   :weight: 5
+  :idempotent: 
 - :name: pipeline_processing:pipeline_update
   :feature_category: :continuous_integration
   :has_external_dependencies: 
   :latency_sensitive: true
   :resource_boundary: :unknown
   :weight: 5
+  :idempotent: 
 - :name: pipeline_processing:stage_update
   :feature_category: :continuous_integration
   :has_external_dependencies: 
   :latency_sensitive: true
   :resource_boundary: :unknown
   :weight: 5
+  :idempotent: 
 - :name: pipeline_processing:update_head_pipeline_for_merge_request
   :feature_category: :continuous_integration
   :has_external_dependencies: 
   :latency_sensitive: true
   :resource_boundary: :cpu
   :weight: 5
+  :idempotent: 
 - :name: repository_check:repository_check_batch
   :feature_category: :source_code_management
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: repository_check:repository_check_clear
   :feature_category: :source_code_management
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: repository_check:repository_check_single_repository
   :feature_category: :source_code_management
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: todos_destroyer:todos_destroyer_confidential_issue
   :feature_category: :issue_tracking
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: todos_destroyer:todos_destroyer_entity_leave
   :feature_category: :issue_tracking
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: todos_destroyer:todos_destroyer_group_private
   :feature_category: :issue_tracking
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: todos_destroyer:todos_destroyer_private_features
   :feature_category: :issue_tracking
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: todos_destroyer:todos_destroyer_project_private
   :feature_category: :issue_tracking
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: update_namespace_statistics:namespaces_root_statistics
   :feature_category: :source_code_management
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: update_namespace_statistics:namespaces_schedule_aggregation
   :feature_category: :source_code_management
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: authorized_projects
   :feature_category: :authentication_and_authorization
   :has_external_dependencies: 
   :latency_sensitive: true
   :resource_boundary: :unknown
   :weight: 2
+  :idempotent: 
 - :name: background_migration
   :feature_category: :not_owned
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: chat_notification
   :feature_category: :chatops
   :has_external_dependencies: 
   :latency_sensitive: true
   :resource_boundary: :unknown
   :weight: 2
+  :idempotent: 
 - :name: create_commit_signature
   :feature_category: :source_code_management
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 2
+  :idempotent: 
 - :name: create_evidence
   :feature_category: :release_governance
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 2
+  :idempotent: 
 - :name: create_note_diff_file
   :feature_category: :source_code_management
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: default
   :feature_category: 
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: 
   :weight: 1
+  :idempotent: 
 - :name: delete_diff_files
   :feature_category: :source_code_management
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: delete_merged_branches
   :feature_category: :source_code_management
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: delete_stored_files
   :feature_category: :not_owned
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: delete_user
   :feature_category: :authentication_and_authorization
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: detect_repository_languages
   :feature_category: :source_code_management
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: email_receiver
   :feature_category: :issue_tracking
   :has_external_dependencies: 
   :latency_sensitive: true
   :resource_boundary: :unknown
   :weight: 2
+  :idempotent: 
 - :name: emails_on_push
   :feature_category: :source_code_management
   :has_external_dependencies: 
   :latency_sensitive: true
   :resource_boundary: :cpu
   :weight: 2
+  :idempotent: 
 - :name: error_tracking_issue_link
   :feature_category: :error_tracking
   :has_external_dependencies: true
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: expire_build_instance_artifacts
   :feature_category: :continuous_integration
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: file_hook
   :feature_category: :integrations
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: git_garbage_collect
   :feature_category: :gitaly
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: github_import_advance_stage
   :feature_category: :importers
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: gitlab_shell
   :feature_category: :source_code_management
   :has_external_dependencies: 
   :latency_sensitive: true
   :resource_boundary: :unknown
   :weight: 2
+  :idempotent: 
 - :name: group_destroy
   :feature_category: :subgroups
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: group_export
   :feature_category: :importers
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: group_import
   :feature_category: :importers
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: import_issues_csv
   :feature_category: :issue_tracking
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :cpu
   :weight: 2
+  :idempotent: 
 - :name: invalid_gpg_signature_update
   :feature_category: :source_code_management
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 2
+  :idempotent: 
 - :name: irker
   :feature_category: :integrations
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: mailers
   :feature_category: 
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: 
   :weight: 2
+  :idempotent: 
 - :name: merge
   :feature_category: :source_code_management
   :has_external_dependencies: 
   :latency_sensitive: true
   :resource_boundary: :unknown
   :weight: 5
+  :idempotent: 
 - :name: merge_request_mergeability_check
   :feature_category: :source_code_management
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: migrate_external_diffs
   :feature_category: :source_code_management
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: namespaceless_project_destroy
   :feature_category: :authentication_and_authorization
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: new_issue
   :feature_category: :issue_tracking
   :has_external_dependencies: 
   :latency_sensitive: true
   :resource_boundary: :cpu
   :weight: 2
+  :idempotent: 
 - :name: new_merge_request
   :feature_category: :source_code_management
   :has_external_dependencies: 
   :latency_sensitive: true
   :resource_boundary: :cpu
   :weight: 2
+  :idempotent: 
 - :name: new_note
   :feature_category: :issue_tracking
   :has_external_dependencies: 
   :latency_sensitive: true
   :resource_boundary: :cpu
   :weight: 2
+  :idempotent: 
 - :name: pages
   :feature_category: :pages
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: pages_domain_ssl_renewal
   :feature_category: :pages
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: pages_domain_verification
   :feature_category: :pages
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: phabricator_import_import_tasks
   :feature_category: :importers
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: post_receive
   :feature_category: :source_code_management
   :has_external_dependencies: 
   :latency_sensitive: true
   :resource_boundary: :cpu
   :weight: 5
+  :idempotent: 
 - :name: process_commit
   :feature_category: :source_code_management
   :has_external_dependencies: 
   :latency_sensitive: true
   :resource_boundary: :unknown
   :weight: 3
+  :idempotent: 
 - :name: project_cache
   :feature_category: :source_code_management
   :has_external_dependencies: 
   :latency_sensitive: true
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: project_daily_statistics
   :feature_category: :source_code_management
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: project_destroy
   :feature_category: :source_code_management
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: project_export
   :feature_category: :importers
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :memory
   :weight: 1
+  :idempotent: 
 - :name: project_service
   :feature_category: :integrations
   :has_external_dependencies: true
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: propagate_service_template
   :feature_category: :source_code_management
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: reactive_caching
   :feature_category: :not_owned
   :has_external_dependencies: 
   :latency_sensitive: true
   :resource_boundary: :cpu
   :weight: 1
+  :idempotent: 
 - :name: rebase
   :feature_category: :source_code_management
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 2
+  :idempotent: 
 - :name: remote_mirror_notification
   :feature_category: :source_code_management
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 2
+  :idempotent: 
 - :name: repository_cleanup
   :feature_category: :source_code_management
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: repository_fork
   :feature_category: :source_code_management
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: repository_import
   :feature_category: :importers
   :has_external_dependencies: true
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: repository_remove_remote
   :feature_category: :source_code_management
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: repository_update_remote_mirror
   :feature_category: :source_code_management
   :has_external_dependencies: true
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: self_monitoring_project_create
   :feature_category: :metrics
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 2
+  :idempotent: 
 - :name: self_monitoring_project_delete
   :feature_category: :metrics
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 2
+  :idempotent: 
 - :name: system_hook_push
   :feature_category: :source_code_management
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: update_external_pull_requests
   :feature_category: :source_code_management
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 3
+  :idempotent: 
 - :name: update_merge_requests
   :feature_category: :source_code_management
   :has_external_dependencies: 
   :latency_sensitive: true
   :resource_boundary: :cpu
   :weight: 3
+  :idempotent: 
 - :name: update_project_statistics
   :feature_category: :source_code_management
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: upload_checksum
   :feature_category: :geo_replication
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: web_hook
   :feature_category: :integrations
   :has_external_dependencies: true
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 

app/workers/archive_trace_worker.rb

 # frozen_string_literal: true
 
-class ArchiveTraceWorker
+class ArchiveTraceWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include PipelineBackgroundQueue
 

app/workers/authorized_projects_worker.rb

 # frozen_string_literal: true
 
-class AuthorizedProjectsWorker
+class AuthorizedProjectsWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   prepend WaitableWorker
 

app/workers/auto_devops/disable_worker.rb

 # frozen_string_literal: true
 
 module AutoDevops
-  class DisableWorker
+  class DisableWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
     include AutoDevopsQueue
 

app/workers/auto_merge_process_worker.rb

 # frozen_string_literal: true
 
-class AutoMergeProcessWorker
+class AutoMergeProcessWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   queue_namespace :auto_merge

app/workers/background_migration_worker.rb

 # frozen_string_literal: true
 
-class BackgroundMigrationWorker
+class BackgroundMigrationWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   feature_category_not_owned!

app/workers/build_coverage_worker.rb

 # frozen_string_literal: true
 
-class BuildCoverageWorker
+class BuildCoverageWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include PipelineQueue
 

app/workers/build_finished_worker.rb

 # frozen_string_literal: true
 
-class BuildFinishedWorker
+class BuildFinishedWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include PipelineQueue
 

app/workers/build_hooks_worker.rb

 # frozen_string_literal: true
 
-class BuildHooksWorker
+class BuildHooksWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include PipelineQueue
 

app/workers/build_queue_worker.rb

 # frozen_string_literal: true
 
-class BuildQueueWorker
+class BuildQueueWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include PipelineQueue
 

app/workers/build_success_worker.rb

 # frozen_string_literal: true
 
-class BuildSuccessWorker
+class BuildSuccessWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include PipelineQueue
 

app/workers/build_trace_sections_worker.rb

 # frozen_string_literal: true
 
-class BuildTraceSectionsWorker
+class BuildTraceSectionsWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include PipelineQueue
 

app/workers/chaos/cpu_spin_worker.rb

 # frozen_string_literal: true
 
 module Chaos
-  class CpuSpinWorker
+  class CpuSpinWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
     include ChaosQueue
 

app/workers/chaos/db_spin_worker.rb

 # frozen_string_literal: true
 
 module Chaos
-  class DbSpinWorker
+  class DbSpinWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
     include ChaosQueue
 

app/workers/chaos/kill_worker.rb

 # frozen_string_literal: true
 
 module Chaos
-  class KillWorker
+  class KillWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
     include ChaosQueue
 

app/workers/chaos/leak_mem_worker.rb

 # frozen_string_literal: true
 
 module Chaos
-  class LeakMemWorker
+  class LeakMemWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
     include ChaosQueue
 

app/workers/chaos/sleep_worker.rb

 # frozen_string_literal: true
 
 module Chaos
-  class SleepWorker
+  class SleepWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
     include ChaosQueue
 

app/workers/chat_notification_worker.rb

 # frozen_string_literal: true
 
-class ChatNotificationWorker
+class ChatNotificationWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   TimeoutExceeded = Class.new(StandardError)

app/workers/ci/archive_traces_cron_worker.rb

 # frozen_string_literal: true
 
 module Ci
-  class ArchiveTracesCronWorker
+  class ArchiveTracesCronWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
     include CronjobQueue # rubocop:disable Scalability/CronWorkerContext
 

app/workers/ci/build_prepare_worker.rb

 # frozen_string_literal: true
 
 module Ci
-  class BuildPrepareWorker
+  class BuildPrepareWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
     include PipelineQueue
 

app/workers/ci/build_schedule_worker.rb

 # frozen_string_literal: true
 
 module Ci
-  class BuildScheduleWorker
+  class BuildScheduleWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
     include PipelineQueue
 

app/workers/ci/build_trace_chunk_flush_worker.rb

 # frozen_string_literal: true
 
 module Ci
-  class BuildTraceChunkFlushWorker
+  class BuildTraceChunkFlushWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
     include PipelineBackgroundQueue
 

app/workers/ci/create_cross_project_pipeline_worker.rb

 # frozen_string_literal: true
 
 module Ci
-  class CreateCrossProjectPipelineWorker
+  class CreateCrossProjectPipelineWorker # rubocop:disable Scalability/IdempotentWorker
     include ::ApplicationWorker
     include ::PipelineQueue
 

app/workers/ci/pipeline_bridge_status_worker.rb

 # frozen_string_literal: true
 
 module Ci
-  class PipelineBridgeStatusWorker
+  class PipelineBridgeStatusWorker # rubocop:disable Scalability/IdempotentWorker
     include ::ApplicationWorker
     include ::PipelineQueue
 

app/workers/ci/resource_groups/assign_resource_from_resource_group_worker.rb

@@ -2,7 +2,7 @@
 
 module Ci
   module ResourceGroups
-    class AssignResourceFromResourceGroupWorker
+    class AssignResourceFromResourceGroupWorker # rubocop:disable Scalability/IdempotentWorker
       include ApplicationWorker
       include PipelineQueue
 

app/workers/cleanup_container_repository_worker.rb

 # frozen_string_literal: true
 
-class CleanupContainerRepositoryWorker
+class CleanupContainerRepositoryWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   queue_namespace :container_repository

app/workers/cluster_configure_istio_worker.rb

 # frozen_string_literal: true
 
-class ClusterConfigureIstioWorker
+class ClusterConfigureIstioWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include ClusterQueue
 

app/workers/cluster_configure_worker.rb

 # frozen_string_literal: true
 
-class ClusterConfigureWorker
+class ClusterConfigureWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include ClusterQueue
 

app/workers/cluster_install_app_worker.rb

 # frozen_string_literal: true
 
-class ClusterInstallAppWorker
+class ClusterInstallAppWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include ClusterQueue
   include ClusterApplications

app/workers/cluster_patch_app_worker.rb

 # frozen_string_literal: true
 
-class ClusterPatchAppWorker
+class ClusterPatchAppWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include ClusterQueue
   include ClusterApplications

app/workers/cluster_project_configure_worker.rb

 # frozen_string_literal: true
 
-class ClusterProjectConfigureWorker
+class ClusterProjectConfigureWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include ClusterQueue
 

app/workers/cluster_provision_worker.rb

 # frozen_string_literal: true
 
-class ClusterProvisionWorker
+class ClusterProvisionWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include ClusterQueue
 

app/workers/cluster_upgrade_app_worker.rb

 # frozen_string_literal: true
 
-class ClusterUpgradeAppWorker
+class ClusterUpgradeAppWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include ClusterQueue
   include ClusterApplications

app/workers/cluster_wait_for_app_installation_worker.rb

 # frozen_string_literal: true
 
-class ClusterWaitForAppInstallationWorker
+class ClusterWaitForAppInstallationWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include ClusterQueue
   include ClusterApplications

app/workers/cluster_wait_for_ingress_ip_address_worker.rb

 # frozen_string_literal: true
 
-class ClusterWaitForIngressIpAddressWorker
+class ClusterWaitForIngressIpAddressWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include ClusterQueue
   include ClusterApplications

app/workers/clusters/applications/activate_service_worker.rb

@@ -2,7 +2,7 @@
 
 module Clusters
   module Applications
-    class ActivateServiceWorker
+    class ActivateServiceWorker # rubocop:disable Scalability/IdempotentWorker
       include ApplicationWorker
       include ClusterQueue
 

app/workers/clusters/applications/deactivate_service_worker.rb

@@ -2,7 +2,7 @@
 
 module Clusters
   module Applications
-    class DeactivateServiceWorker
+    class DeactivateServiceWorker # rubocop:disable Scalability/IdempotentWorker
       include ApplicationWorker
       include ClusterQueue
 

app/workers/clusters/applications/uninstall_worker.rb

@@ -2,7 +2,7 @@
 
 module Clusters
   module Applications
-    class UninstallWorker
+    class UninstallWorker # rubocop:disable Scalability/IdempotentWorker
       include ApplicationWorker
       include ClusterQueue
       include ClusterApplications

app/workers/clusters/applications/wait_for_uninstall_app_worker.rb

@@ -2,7 +2,7 @@
 
 module Clusters
   module Applications
-    class WaitForUninstallAppWorker
+    class WaitForUninstallAppWorker # rubocop:disable Scalability/IdempotentWorker
       include ApplicationWorker
       include ClusterQueue
       include ClusterApplications

app/workers/clusters/cleanup/app_worker.rb

@@ -2,7 +2,7 @@
 
 module Clusters
   module Cleanup
-    class AppWorker
+    class AppWorker # rubocop:disable Scalability/IdempotentWorker
       include ClusterCleanupMethods
 
       def perform(cluster_id, execution_count = 0)

app/workers/clusters/cleanup/project_namespace_worker.rb

@@ -2,7 +2,7 @@
 
 module Clusters
   module Cleanup
-    class ProjectNamespaceWorker
+    class ProjectNamespaceWorker # rubocop:disable Scalability/IdempotentWorker
       include ClusterCleanupMethods
 
       def perform(cluster_id, execution_count = 0)

app/workers/clusters/cleanup/service_account_worker.rb

@@ -2,7 +2,7 @@
 
 module Clusters
   module Cleanup
-    class ServiceAccountWorker
+    class ServiceAccountWorker # rubocop:disable Scalability/IdempotentWorker
       include ClusterCleanupMethods
 
       def perform(cluster_id)

app/workers/concerns/worker_attributes.rb

@@ -89,6 +89,14 @@ module WorkerAttributes
       worker_attributes[:resource_boundary] || :unknown
     end
 
+    def idempotent!
+      worker_attributes[:idempotent] = true
+    end
+
+    def idempotent?
+      worker_attributes[:idempotent]
+    end
+
     def weight(value)
       worker_attributes[:weight] = value
     end

app/workers/container_expiration_policy_worker.rb

 # frozen_string_literal: true
 
-class ContainerExpirationPolicyWorker
+class ContainerExpirationPolicyWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include CronjobQueue
 

app/workers/create_commit_signature_worker.rb

 # frozen_string_literal: true
 
-class CreateCommitSignatureWorker
+class CreateCommitSignatureWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   feature_category :source_code_management

app/workers/create_evidence_worker.rb

 # frozen_string_literal: true
 
-class CreateEvidenceWorker
+class CreateEvidenceWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   feature_category :release_governance

app/workers/create_note_diff_file_worker.rb

 # frozen_string_literal: true
 
-class CreateNoteDiffFileWorker
+class CreateNoteDiffFileWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   feature_category :source_code_management

app/workers/create_pipeline_worker.rb

 # frozen_string_literal: true
 
-class CreatePipelineWorker
+class CreatePipelineWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include PipelineQueue
 

app/workers/delete_container_repository_worker.rb

 # frozen_string_literal: true
 
-class DeleteContainerRepositoryWorker
+class DeleteContainerRepositoryWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include ExclusiveLeaseGuard
 

app/workers/delete_diff_files_worker.rb

 # frozen_string_literal: true
 
-class DeleteDiffFilesWorker
+class DeleteDiffFilesWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   feature_category :source_code_management

app/workers/delete_merged_branches_worker.rb

 # frozen_string_literal: true
 
-class DeleteMergedBranchesWorker
+class DeleteMergedBranchesWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   feature_category :source_code_management

app/workers/delete_stored_files_worker.rb

 # frozen_string_literal: true
 
-class DeleteStoredFilesWorker
+class DeleteStoredFilesWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   feature_category_not_owned!

app/workers/delete_user_worker.rb

 # frozen_string_literal: true
 
-class DeleteUserWorker
+class DeleteUserWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   feature_category :authentication_and_authorization

app/workers/deployments/finished_worker.rb

 # frozen_string_literal: true
 
 module Deployments
-  class FinishedWorker
+  class FinishedWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
     queue_namespace :deployment

app/workers/deployments/forward_deployment_worker.rb

 # frozen_string_literal: true
 
 module Deployments
-  class ForwardDeploymentWorker
+  class ForwardDeploymentWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
     queue_namespace :deployment

app/workers/deployments/success_worker.rb

 # frozen_string_literal: true
 
 module Deployments
-  class SuccessWorker
+  class SuccessWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
     queue_namespace :deployment

app/workers/detect_repository_languages_worker.rb

 # frozen_string_literal: true
 
-class DetectRepositoryLanguagesWorker
+class DetectRepositoryLanguagesWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include ExceptionBacktrace
   include ExclusiveLeaseGuard

app/workers/email_receiver_worker.rb

 # frozen_string_literal: true
 
-class EmailReceiverWorker
+class EmailReceiverWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   feature_category :issue_tracking

app/workers/emails_on_push_worker.rb

 # frozen_string_literal: true
 
-class EmailsOnPushWorker
+class EmailsOnPushWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   attr_reader :email, :skip_premailer

app/workers/environments/auto_stop_cron_worker.rb

 # frozen_string_literal: true
 
 module Environments
-  class AutoStopCronWorker
+  class AutoStopCronWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
     include CronjobQueue # rubocop:disable Scalability/CronWorkerContext
 

app/workers/error_tracking_issue_link_worker.rb

@@ -5,7 +5,7 @@
 # If a link to a different GitLab issue exists, a new link
 #   will still be created, but will not be visible in Sentry
 #   until the prior link is deleted.
-class ErrorTrackingIssueLinkWorker
+class ErrorTrackingIssueLinkWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include ExclusiveLeaseGuard
   include Gitlab::Utils::StrongMemoize

app/workers/expire_build_artifacts_worker.rb

 # frozen_string_literal: true
 
-class ExpireBuildArtifactsWorker
+class ExpireBuildArtifactsWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   # rubocop:disable Scalability/CronWorkerContext
   # This worker does not perform work scoped to a context

app/workers/expire_build_instance_artifacts_worker.rb

 # frozen_string_literal: true
 
-class ExpireBuildInstanceArtifactsWorker
+class ExpireBuildInstanceArtifactsWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   feature_category :continuous_integration

app/workers/expire_job_cache_worker.rb

@@ -6,6 +6,7 @@ class ExpireJobCacheWorker
 
   queue_namespace :pipeline_cache
   latency_sensitive_worker!
+  idempotent!
 
   # rubocop: disable CodeReuse/ActiveRecord
   def perform(job_id)

app/workers/expire_pipeline_cache_worker.rb

 # frozen_string_literal: true
 
-class ExpirePipelineCacheWorker
+class ExpirePipelineCacheWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include PipelineQueue
 

app/workers/file_hook_worker.rb

 # frozen_string_literal: true
 
-class FileHookWorker
+class FileHookWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   sidekiq_options retry: false

app/workers/git_garbage_collect_worker.rb

 # frozen_string_literal: true
 
-class GitGarbageCollectWorker
+class GitGarbageCollectWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   sidekiq_options retry: false

app/workers/gitlab/github_import/advance_stage_worker.rb

@@ -6,7 +6,7 @@ module Gitlab
     # number of jobs to complete, without blocking a thread. Once all jobs have
     # been completed this worker will advance the import process to the next
     # stage.
-    class AdvanceStageWorker
+    class AdvanceStageWorker # rubocop:disable Scalability/IdempotentWorker
       include ApplicationWorker
 
       sidekiq_options dead: false

app/workers/gitlab/github_import/import_diff_note_worker.rb

@@ -2,7 +2,7 @@
 
 module Gitlab
   module GithubImport
-    class ImportDiffNoteWorker
+    class ImportDiffNoteWorker # rubocop:disable Scalability/IdempotentWorker
       include ObjectImporter
 
       def representation_class

app/workers/gitlab/github_import/import_issue_worker.rb

@@ -2,7 +2,7 @@
 
 module Gitlab
   module GithubImport
-    class ImportIssueWorker
+    class ImportIssueWorker # rubocop:disable Scalability/IdempotentWorker
       include ObjectImporter
 
       def representation_class

app/workers/gitlab/github_import/import_lfs_object_worker.rb

@@ -2,7 +2,7 @@
 
 module Gitlab
   module GithubImport
-    class ImportLfsObjectWorker
+    class ImportLfsObjectWorker # rubocop:disable Scalability/IdempotentWorker
       include ObjectImporter
 
       def representation_class

app/workers/gitlab/github_import/import_note_worker.rb

@@ -2,7 +2,7 @@
 
 module Gitlab
   module GithubImport
-    class ImportNoteWorker
+    class ImportNoteWorker # rubocop:disable Scalability/IdempotentWorker
       include ObjectImporter
 
       def representation_class

app/workers/gitlab/github_import/import_pull_request_worker.rb

@@ -2,7 +2,7 @@
 
 module Gitlab
   module GithubImport
-    class ImportPullRequestWorker
+    class ImportPullRequestWorker # rubocop:disable Scalability/IdempotentWorker
       include ObjectImporter
 
       def representation_class

app/workers/gitlab/github_import/refresh_import_jid_worker.rb

@@ -2,7 +2,7 @@
 
 module Gitlab
   module GithubImport
-    class RefreshImportJidWorker
+    class RefreshImportJidWorker # rubocop:disable Scalability/IdempotentWorker
       include ApplicationWorker
       include GithubImport::Queue
 

app/workers/gitlab/github_import/stage/finish_import_worker.rb

@@ -3,7 +3,7 @@
 module Gitlab
   module GithubImport
     module Stage
-      class FinishImportWorker
+      class FinishImportWorker # rubocop:disable Scalability/IdempotentWorker
         include ApplicationWorker
         include GithubImport::Queue
         include StageMethods

app/workers/gitlab/github_import/stage/import_base_data_worker.rb

@@ -3,7 +3,7 @@
 module Gitlab
   module GithubImport
     module Stage
-      class ImportBaseDataWorker
+      class ImportBaseDataWorker # rubocop:disable Scalability/IdempotentWorker
         include ApplicationWorker
         include GithubImport::Queue
         include StageMethods

app/workers/gitlab/github_import/stage/import_issues_and_diff_notes_worker.rb

@@ -3,7 +3,7 @@
 module Gitlab
   module GithubImport
     module Stage
-      class ImportIssuesAndDiffNotesWorker
+      class ImportIssuesAndDiffNotesWorker # rubocop:disable Scalability/IdempotentWorker
         include ApplicationWorker
         include GithubImport::Queue
         include StageMethods

app/workers/gitlab/github_import/stage/import_lfs_objects_worker.rb

@@ -3,7 +3,7 @@
 module Gitlab
   module GithubImport
     module Stage
-      class ImportLfsObjectsWorker
+      class ImportLfsObjectsWorker # rubocop:disable Scalability/IdempotentWorker
         include ApplicationWorker
         include GithubImport::Queue
         include StageMethods

app/workers/gitlab/github_import/stage/import_notes_worker.rb

@@ -3,7 +3,7 @@
 module Gitlab
   module GithubImport
     module Stage
-      class ImportNotesWorker
+      class ImportNotesWorker # rubocop:disable Scalability/IdempotentWorker
         include ApplicationWorker
         include GithubImport::Queue
         include StageMethods

app/workers/gitlab/github_import/stage/import_pull_requests_worker.rb

@@ -3,7 +3,7 @@
 module Gitlab
   module GithubImport
     module Stage
-      class ImportPullRequestsWorker
+      class ImportPullRequestsWorker # rubocop:disable Scalability/IdempotentWorker
         include ApplicationWorker
         include GithubImport::Queue
         include StageMethods

app/workers/gitlab/github_import/stage/import_repository_worker.rb

@@ -3,7 +3,7 @@
 module Gitlab
   module GithubImport
     module Stage
-      class ImportRepositoryWorker
+      class ImportRepositoryWorker # rubocop:disable Scalability/IdempotentWorker
         include ApplicationWorker
         include GithubImport::Queue
         include StageMethods

app/workers/gitlab/phabricator_import/base_worker.rb

@@ -18,7 +18,7 @@
 # - It marks the import as finished when all remaining jobs are done
 module Gitlab
   module PhabricatorImport
-    class BaseWorker
+    class BaseWorker # rubocop:disable Scalability/IdempotentWorker
       include WorkerAttributes
       include Gitlab::ExclusiveLeaseHelpers
 

app/workers/gitlab/phabricator_import/import_tasks_worker.rb

 # frozen_string_literal: true
 module Gitlab
   module PhabricatorImport
-    class ImportTasksWorker < BaseWorker
+    class ImportTasksWorker < BaseWorker # rubocop:disable Scalability/IdempotentWorker
       include ApplicationWorker
       include ProjectImportOptions # This marks the project as failed after too many tries
 

app/workers/gitlab_shell_worker.rb

 # frozen_string_literal: true
 
-class GitlabShellWorker
+class GitlabShellWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include Gitlab::ShellAdapter
 

app/workers/gitlab_usage_ping_worker.rb

 # frozen_string_literal: true
 
-class GitlabUsagePingWorker
+class GitlabUsagePingWorker # rubocop:disable Scalability/IdempotentWorker
   LEASE_TIMEOUT = 86400
 
   include ApplicationWorker

app/workers/group_destroy_worker.rb

 # frozen_string_literal: true
 
-class GroupDestroyWorker
+class GroupDestroyWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include ExceptionBacktrace
 

app/workers/group_export_worker.rb

 # frozen_string_literal: true
 
-class GroupExportWorker
+class GroupExportWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include ExceptionBacktrace
 

app/workers/group_import_worker.rb

 # frozen_string_literal: true
 
-class GroupImportWorker
+class GroupImportWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include ExceptionBacktrace
 

app/workers/hashed_storage/base_worker.rb

 # frozen_string_literal: true
 
 module HashedStorage
-  class BaseWorker
+  class BaseWorker # rubocop:disable Scalability/IdempotentWorker
     include ExclusiveLeaseGuard
     include WorkerAttributes
 

app/workers/hashed_storage/migrator_worker.rb

 # frozen_string_literal: true
 
 module HashedStorage
-  class MigratorWorker
+  class MigratorWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
     queue_namespace :hashed_storage

app/workers/hashed_storage/project_migrate_worker.rb

 # frozen_string_literal: true
 
 module HashedStorage
-  class ProjectMigrateWorker < BaseWorker
+  class ProjectMigrateWorker < BaseWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
     queue_namespace :hashed_storage

app/workers/hashed_storage/project_rollback_worker.rb

 # frozen_string_literal: true
 
 module HashedStorage
-  class ProjectRollbackWorker < BaseWorker
+  class ProjectRollbackWorker < BaseWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
     queue_namespace :hashed_storage

app/workers/hashed_storage/rollbacker_worker.rb

 # frozen_string_literal: true
 
 module HashedStorage
-  class RollbackerWorker
+  class RollbackerWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
     queue_namespace :hashed_storage

app/workers/import_export_project_cleanup_worker.rb

 # frozen_string_literal: true
 
-class ImportExportProjectCleanupWorker
+class ImportExportProjectCleanupWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   # rubocop:disable Scalability/CronWorkerContext
   # This worker does not perform work scoped to a context

app/workers/import_issues_csv_worker.rb

 # frozen_string_literal: true
 
-class ImportIssuesCsvWorker
+class ImportIssuesCsvWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   feature_category :issue_tracking

app/workers/incident_management/process_alert_worker.rb

 # frozen_string_literal: true
 
 module IncidentManagement
-  class ProcessAlertWorker
+  class ProcessAlertWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
     queue_namespace :incident_management

app/workers/invalid_gpg_signature_update_worker.rb

 # frozen_string_literal: true
 
-class InvalidGpgSignatureUpdateWorker
+class InvalidGpgSignatureUpdateWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   feature_category :source_code_management

app/workers/irker_worker.rb

@@ -3,7 +3,7 @@
 require 'json'
 require 'socket'
 
-class IrkerWorker
+class IrkerWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   feature_category :integrations

app/workers/issue_due_scheduler_worker.rb

 # frozen_string_literal: true
 
-class IssueDueSchedulerWorker
+class IssueDueSchedulerWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include CronjobQueue # rubocop:disable Scalability/CronWorkerContext
 

app/workers/mail_scheduler/issue_due_worker.rb

 # frozen_string_literal: true
 
 module MailScheduler
-  class IssueDueWorker
+  class IssueDueWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
     include MailSchedulerQueue
 

app/workers/mail_scheduler/notification_service_worker.rb

@@ -3,7 +3,7 @@
 require 'active_job/arguments'
 
 module MailScheduler
-  class NotificationServiceWorker
+  class NotificationServiceWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
     include MailSchedulerQueue
 

app/workers/merge_request_mergeability_check_worker.rb

 # frozen_string_literal: true
 
-class MergeRequestMergeabilityCheckWorker
+class MergeRequestMergeabilityCheckWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   feature_category :source_code_management

app/workers/merge_worker.rb

 # frozen_string_literal: true
 
-class MergeWorker
+class MergeWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   feature_category :source_code_management

app/workers/migrate_external_diffs_worker.rb

 # frozen_string_literal: true
 
-class MigrateExternalDiffsWorker
+class MigrateExternalDiffsWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   feature_category :source_code_management

app/workers/namespaceless_project_destroy_worker.rb

@@ -6,7 +6,7 @@
 # used to belong to. Projects in this state should be rare.
 # The worker will reject doing anything for projects that *do* have a
 # namespace. For those use ProjectDestroyWorker instead.
-class NamespacelessProjectDestroyWorker
+class NamespacelessProjectDestroyWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include ExceptionBacktrace
 

app/workers/namespaces/prune_aggregation_schedules_worker.rb

 # frozen_string_literal: true
 
 module Namespaces
-  class PruneAggregationSchedulesWorker
+  class PruneAggregationSchedulesWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
     include CronjobQueue # rubocop:disable Scalability/CronWorkerContext
 

app/workers/namespaces/root_statistics_worker.rb

 # frozen_string_literal: true
 
 module Namespaces
-  class RootStatisticsWorker
+  class RootStatisticsWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
     queue_namespace :update_namespace_statistics

app/workers/namespaces/schedule_aggregation_worker.rb

 # frozen_string_literal: true
 
 module Namespaces
-  class ScheduleAggregationWorker
+  class ScheduleAggregationWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
     queue_namespace :update_namespace_statistics

app/workers/new_issue_worker.rb

 # frozen_string_literal: true
 
-class NewIssueWorker
+class NewIssueWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include NewIssuable
 

app/workers/new_merge_request_worker.rb

 # frozen_string_literal: true
 
-class NewMergeRequestWorker
+class NewMergeRequestWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include NewIssuable
 

app/workers/new_note_worker.rb

 # frozen_string_literal: true
 
-class NewNoteWorker
+class NewNoteWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   feature_category :issue_tracking

app/workers/new_release_worker.rb

 # frozen_string_literal: true
 
-class NewReleaseWorker
+class NewReleaseWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   queue_namespace :notifications

app/workers/object_pool/create_worker.rb

 # frozen_string_literal: true
 
 module ObjectPool
-  class CreateWorker
+  class CreateWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
     include ObjectPoolQueue
     include ExclusiveLeaseGuard

app/workers/object_pool/destroy_worker.rb

 # frozen_string_literal: true
 
 module ObjectPool
-  class DestroyWorker
+  class DestroyWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
     include ObjectPoolQueue
 

app/workers/object_pool/join_worker.rb

 # frozen_string_literal: true
 
 module ObjectPool
-  class JoinWorker
+  class JoinWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
     include ObjectPoolQueue
 

app/workers/object_pool/schedule_join_worker.rb

 # frozen_string_literal: true
 
 module ObjectPool
-  class ScheduleJoinWorker
+  class ScheduleJoinWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
     include ObjectPoolQueue
 

app/workers/object_storage/background_move_worker.rb

 # frozen_string_literal: true
 
 module ObjectStorage
-  class BackgroundMoveWorker
+  class BackgroundMoveWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
     include ObjectStorageQueue
 

app/workers/object_storage/migrate_uploads_worker.rb

 # frozen_string_literal: true
 
+# rubocop:disable Scalability/IdempotentWorker
 module ObjectStorage
   class MigrateUploadsWorker
     include ApplicationWorker
@@ -137,3 +138,4 @@ module ObjectStorage
     end
   end
 end
+# rubocop:enable Scalability/IdempotentWorker

app/workers/pages_domain_removal_cron_worker.rb

 # frozen_string_literal: true
 
-class PagesDomainRemovalCronWorker
+class PagesDomainRemovalCronWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include CronjobQueue
 

app/workers/pages_domain_ssl_renewal_cron_worker.rb

 # frozen_string_literal: true
 
-class PagesDomainSslRenewalCronWorker
+class PagesDomainSslRenewalCronWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include CronjobQueue
 

app/workers/pages_domain_ssl_renewal_worker.rb

 # frozen_string_literal: true
 
-class PagesDomainSslRenewalWorker
+class PagesDomainSslRenewalWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   feature_category :pages

app/workers/pages_domain_verification_cron_worker.rb

 # frozen_string_literal: true
 
-class PagesDomainVerificationCronWorker
+class PagesDomainVerificationCronWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include CronjobQueue
 

app/workers/pages_domain_verification_worker.rb

 # frozen_string_literal: true
 
-class PagesDomainVerificationWorker
+class PagesDomainVerificationWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   feature_category :pages

app/workers/pages_worker.rb

 # frozen_string_literal: true
 
-class PagesWorker
+class PagesWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   sidekiq_options retry: 3

app/workers/personal_access_tokens/expiring_worker.rb

 # frozen_string_literal: true
 
 module PersonalAccessTokens
-  class ExpiringWorker
+  class ExpiringWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
     include CronjobQueue
 

app/workers/pipeline_hooks_worker.rb

 # frozen_string_literal: true
 
-class PipelineHooksWorker
+class PipelineHooksWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include PipelineQueue
 

app/workers/pipeline_metrics_worker.rb

 # frozen_string_literal: true
 
-class PipelineMetricsWorker
+class PipelineMetricsWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include PipelineQueue
 

app/workers/pipeline_notification_worker.rb

 # frozen_string_literal: true
 
-class PipelineNotificationWorker
+class PipelineNotificationWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include PipelineQueue
 

app/workers/pipeline_process_worker.rb

 # frozen_string_literal: true
 
-class PipelineProcessWorker
+class PipelineProcessWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include PipelineQueue
 

app/workers/pipeline_schedule_worker.rb

 # frozen_string_literal: true
 
-class PipelineScheduleWorker
+class PipelineScheduleWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include CronjobQueue
 

app/workers/pipeline_success_worker.rb

 # frozen_string_literal: true
 
-class PipelineSuccessWorker
+class PipelineSuccessWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include PipelineQueue
 

app/workers/pipeline_update_worker.rb

 # frozen_string_literal: true
 
-class PipelineUpdateWorker
+class PipelineUpdateWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include PipelineQueue
 

app/workers/post_receive.rb

 # frozen_string_literal: true
 
-class PostReceive
+class PostReceive # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   feature_category :source_code_management

app/workers/process_commit_worker.rb

@@ -7,7 +7,7 @@
 # result of this the workload of this worker should be kept to a bare minimum.
 # Consider using an extra worker if you need to add any extra (and potentially
 # slow) processing of commits.
-class ProcessCommitWorker
+class ProcessCommitWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   feature_category :source_code_management

app/workers/project_cache_worker.rb

 # frozen_string_literal: true
 
 # Worker for updating any project specific caches.
-class ProjectCacheWorker
+class ProjectCacheWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   latency_sensitive_worker!

app/workers/project_daily_statistics_worker.rb

 # frozen_string_literal: true
 
-class ProjectDailyStatisticsWorker
+class ProjectDailyStatisticsWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   feature_category :source_code_management

app/workers/project_destroy_worker.rb

 # frozen_string_literal: true
 
-class ProjectDestroyWorker
+class ProjectDestroyWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include ExceptionBacktrace
 

app/workers/project_export_worker.rb

 # frozen_string_literal: true
 
-class ProjectExportWorker
+class ProjectExportWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include ExceptionBacktrace
 

app/workers/project_service_worker.rb

 # frozen_string_literal: true
 
-class ProjectServiceWorker
+class ProjectServiceWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   sidekiq_options dead: false

app/workers/propagate_service_template_worker.rb

 # frozen_string_literal: true
 
 # Worker for updating any project specific caches.
-class PropagateServiceTemplateWorker
+class PropagateServiceTemplateWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   feature_category :source_code_management

app/workers/prune_old_events_worker.rb

 # frozen_string_literal: true
 
-class PruneOldEventsWorker
+class PruneOldEventsWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   # rubocop:disable Scalability/CronWorkerContext
   # This worker does not perform work scoped to a context

app/workers/prune_web_hook_logs_worker.rb

@@ -2,7 +2,7 @@
 
 # Worker that deletes a fixed number of outdated rows from the "web_hook_logs"
 # table.
-class PruneWebHookLogsWorker
+class PruneWebHookLogsWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   # rubocop:disable Scalability/CronWorkerContext
   # This worker does not perform work scoped to a context

app/workers/reactive_caching_worker.rb

 # frozen_string_literal: true
 
-class ReactiveCachingWorker
+class ReactiveCachingWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   feature_category_not_owned!

app/workers/rebase_worker.rb

@@ -2,7 +2,7 @@
 
 # The RebaseWorker must be wrapped in important concurrency code, so should only
 # be scheduled via MergeRequest#rebase_async
-class RebaseWorker
+class RebaseWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   feature_category :source_code_management

app/workers/remote_mirror_notification_worker.rb

 # frozen_string_literal: true
 
-class RemoteMirrorNotificationWorker
+class RemoteMirrorNotificationWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   feature_category :source_code_management

app/workers/remove_expired_group_links_worker.rb

 # frozen_string_literal: true
 
-class RemoveExpiredGroupLinksWorker
+class RemoveExpiredGroupLinksWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include CronjobQueue # rubocop:disable Scalability/CronWorkerContext
 

app/workers/remove_expired_members_worker.rb

 # frozen_string_literal: true
 
-class RemoveExpiredMembersWorker
+class RemoveExpiredMembersWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include CronjobQueue # rubocop:disable Scalability/CronWorkerContext
 

app/workers/remove_unreferenced_lfs_objects_worker.rb

 # frozen_string_literal: true
 
-class RemoveUnreferencedLfsObjectsWorker
+class RemoveUnreferencedLfsObjectsWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   # rubocop:disable Scalability/CronWorkerContext
   # This worker does not perform work scoped to a context

app/workers/repository_archive_cache_worker.rb

 # frozen_string_literal: true
 
-class RepositoryArchiveCacheWorker
+class RepositoryArchiveCacheWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   # rubocop:disable Scalability/CronWorkerContext
   # This worker does not perform work scoped to a context

app/workers/repository_check/batch_worker.rb

 # frozen_string_literal: true
 
 module RepositoryCheck
-  class BatchWorker
+  class BatchWorker # rubocop:disable Scalability/IdempotentWorker
     prepend_if_ee('::EE::RepositoryCheck::BatchWorker') # rubocop: disable Cop/InjectEnterpriseEditionModule
 
     include ApplicationWorker

app/workers/repository_check/clear_worker.rb

 # frozen_string_literal: true
 
 module RepositoryCheck
-  class ClearWorker
+  class ClearWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
     include RepositoryCheckQueue
 

app/workers/repository_check/dispatch_worker.rb

 # frozen_string_literal: true
 
 module RepositoryCheck
-  class DispatchWorker
+  class DispatchWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
     # rubocop:disable Scalability/CronWorkerContext
     # This worker does not perform work scoped to a context

app/workers/repository_check/single_repository_worker.rb

 # frozen_string_literal: true
 
 module RepositoryCheck
-  class SingleRepositoryWorker
+  class SingleRepositoryWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
     include RepositoryCheckQueue
 

app/workers/repository_cleanup_worker.rb

 # frozen_string_literal: true
 
-class RepositoryCleanupWorker
+class RepositoryCleanupWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   sidekiq_options retry: 3

app/workers/repository_fork_worker.rb

 # frozen_string_literal: true
 
-class RepositoryForkWorker
+class RepositoryForkWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include Gitlab::ShellAdapter
   include ProjectStartImport

app/workers/repository_import_worker.rb

 # frozen_string_literal: true
 
-class RepositoryImportWorker
+class RepositoryImportWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include ExceptionBacktrace
   include ProjectStartImport

app/workers/repository_remove_remote_worker.rb

 # frozen_string_literal: true
 
-class RepositoryRemoveRemoteWorker
+class RepositoryRemoveRemoteWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include ExclusiveLeaseGuard
 

app/workers/repository_update_remote_mirror_worker.rb

 # frozen_string_literal: true
 
-class RepositoryUpdateRemoteMirrorWorker
+class RepositoryUpdateRemoteMirrorWorker # rubocop:disable Scalability/IdempotentWorker
   UpdateError = Class.new(StandardError)
 
   include ApplicationWorker

app/workers/requests_profiles_worker.rb

 # frozen_string_literal: true
 
-class RequestsProfilesWorker
+class RequestsProfilesWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   # rubocop:disable Scalability/CronWorkerContext
   # This worker does not perform work scoped to a context

app/workers/run_pipeline_schedule_worker.rb

 # frozen_string_literal: true
 
-class RunPipelineScheduleWorker
+class RunPipelineScheduleWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include PipelineQueue
 

app/workers/schedule_migrate_external_diffs_worker.rb

 # frozen_string_literal: true
 
-class ScheduleMigrateExternalDiffsWorker
+class ScheduleMigrateExternalDiffsWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   # rubocop:disable Scalability/CronWorkerContext:
   # This schedules the `MigrateExternalDiffsWorker`

app/workers/self_monitoring_project_create_worker.rb

 # frozen_string_literal: true
 
-class SelfMonitoringProjectCreateWorker
+class SelfMonitoringProjectCreateWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include ExclusiveLeaseGuard
   include SelfMonitoringProjectWorker

app/workers/self_monitoring_project_delete_worker.rb

 # frozen_string_literal: true
 
-class SelfMonitoringProjectDeleteWorker
+class SelfMonitoringProjectDeleteWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include ExclusiveLeaseGuard
   include SelfMonitoringProjectWorker

app/workers/stage_update_worker.rb

 # frozen_string_literal: true
 
-class StageUpdateWorker
+class StageUpdateWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include PipelineQueue
 

app/workers/stuck_ci_jobs_worker.rb

 # frozen_string_literal: true
 
-class StuckCiJobsWorker
+class StuckCiJobsWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include CronjobQueue
 

app/workers/stuck_import_jobs_worker.rb

 # frozen_string_literal: true
 
-class StuckImportJobsWorker
+class StuckImportJobsWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   # rubocop:disable Scalability/CronWorkerContext
   # This worker updates several import states inline and does not schedule

app/workers/stuck_merge_jobs_worker.rb

 # frozen_string_literal: true
 
-class StuckMergeJobsWorker
+class StuckMergeJobsWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include CronjobQueue # rubocop:disable Scalability/CronWorkerContext
 

app/workers/system_hook_push_worker.rb

 # frozen_string_literal: true
 
-class SystemHookPushWorker
+class SystemHookPushWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   feature_category :source_code_management

app/workers/todos_destroyer/confidential_issue_worker.rb

 # frozen_string_literal: true
 
 module TodosDestroyer
-  class ConfidentialIssueWorker
+  class ConfidentialIssueWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
     include TodosDestroyerQueue
 

app/workers/todos_destroyer/entity_leave_worker.rb

 # frozen_string_literal: true
 
 module TodosDestroyer
-  class EntityLeaveWorker
+  class EntityLeaveWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
     include TodosDestroyerQueue
 

app/workers/todos_destroyer/group_private_worker.rb

 # frozen_string_literal: true
 
 module TodosDestroyer
-  class GroupPrivateWorker
+  class GroupPrivateWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
     include TodosDestroyerQueue
 

app/workers/todos_destroyer/private_features_worker.rb

 # frozen_string_literal: true
 
 module TodosDestroyer
-  class PrivateFeaturesWorker
+  class PrivateFeaturesWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
     include TodosDestroyerQueue
 

app/workers/todos_destroyer/project_private_worker.rb

 # frozen_string_literal: true
 
 module TodosDestroyer
-  class ProjectPrivateWorker
+  class ProjectPrivateWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
     include TodosDestroyerQueue
 

app/workers/trending_projects_worker.rb

 # frozen_string_literal: true
 
-class TrendingProjectsWorker
+class TrendingProjectsWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   # rubocop:disable Scalability/CronWorkerContext
   # This worker does not perform work scoped to a context

app/workers/update_external_pull_requests_worker.rb

 # frozen_string_literal: true
 
-class UpdateExternalPullRequestsWorker
+class UpdateExternalPullRequestsWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   feature_category :source_code_management

app/workers/update_head_pipeline_for_merge_request_worker.rb

 # frozen_string_literal: true
 
-class UpdateHeadPipelineForMergeRequestWorker
+class UpdateHeadPipelineForMergeRequestWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include PipelineQueue
 

app/workers/update_merge_requests_worker.rb

 # frozen_string_literal: true
 
-class UpdateMergeRequestsWorker
+class UpdateMergeRequestsWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   feature_category :source_code_management

app/workers/update_project_statistics_worker.rb

 # frozen_string_literal: true
 
 # Worker for updating project statistics.
-class UpdateProjectStatisticsWorker
+class UpdateProjectStatisticsWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   feature_category :source_code_management

app/workers/upload_checksum_worker.rb

 # frozen_string_literal: true
 
-class UploadChecksumWorker
+class UploadChecksumWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   feature_category :geo_replication

app/workers/wait_for_cluster_creation_worker.rb

 # frozen_string_literal: true
 
-class WaitForClusterCreationWorker
+class WaitForClusterCreationWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include ClusterQueue
 

app/workers/web_hook_worker.rb

 # frozen_string_literal: true
 
-class WebHookWorker
+class WebHookWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   feature_category :integrations

ee/app/workers/adjourned_group_deletion_worker.rb

 # frozen_string_literal: true
 
-class AdjournedGroupDeletionWorker
+class AdjournedGroupDeletionWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include CronjobQueue
 

ee/app/workers/adjourned_project_deletion_worker.rb

 # frozen_string_literal: true
 
-class AdjournedProjectDeletionWorker
+class AdjournedProjectDeletionWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include ExceptionBacktrace
 

ee/app/workers/adjourned_projects_deletion_cron_worker.rb

 # frozen_string_literal: true
 
-class AdjournedProjectsDeletionCronWorker
+class AdjournedProjectsDeletionCronWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include CronjobQueue
 

ee/app/workers/admin_emails_worker.rb

 # frozen_string_literal: true
 
-class AdminEmailsWorker
+class AdminEmailsWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   feature_category :issue_tracking

ee/app/workers/all_queues.yml

@@ -9,465 +9,543 @@
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: cronjob:adjourned_projects_deletion_cron
   :feature_category: :authentication_and_authorization
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: cronjob:clear_shared_runners_minutes
   :feature_category: :continuous_integration
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: cronjob:geo_container_repository_sync_dispatch
   :feature_category: :geo_replication
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: cronjob:geo_file_download_dispatch
   :feature_category: :geo_replication
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: cronjob:geo_metrics_update
   :feature_category: :geo_replication
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: cronjob:geo_migrated_local_files_clean_up
   :feature_category: :geo_replication
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: cronjob:geo_prune_event_log
   :feature_category: :geo_replication
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: cronjob:geo_repository_sync
   :feature_category: :geo_replication
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: cronjob:geo_repository_verification_primary_batch
   :feature_category: :geo_replication
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: cronjob:geo_repository_verification_secondary_scheduler
   :feature_category: :geo_replication
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: cronjob:geo_repository_verification_secondary_shard
   :feature_category: :geo_replication
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: cronjob:geo_scheduler_per_shard_scheduler
   :feature_category: :geo_replication
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: cronjob:geo_scheduler_primary_per_shard_scheduler
   :feature_category: :geo_replication
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: cronjob:geo_scheduler_secondary_per_shard_scheduler
   :feature_category: :geo_replication
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: cronjob:geo_secondary_registry_consistency
   :feature_category: :geo_replication
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: cronjob:geo_sidekiq_cron_config
   :feature_category: :geo_replication
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: cronjob:historical_data
   :feature_category: :license_compliance
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: cronjob:import_software_licenses
   :feature_category: :license_compliance
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: cronjob:ldap_all_groups_sync
   :feature_category: :authentication_and_authorization
   :has_external_dependencies: true
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: cronjob:ldap_sync
   :feature_category: :authentication_and_authorization
   :has_external_dependencies: true
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: cronjob:pseudonymizer
   :feature_category: :integrations
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: cronjob:update_all_mirrors
   :feature_category: :source_code_management
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: cronjob:update_max_seats_used_for_gitlab_com_subscriptions
   :feature_category: :license_compliance
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :cpu
   :weight: 1
+  :idempotent: 
 - :name: epics:epics_update_epics_dates
   :feature_category: :epics
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 2
+  :idempotent: 
 - :name: gcp_cluster:cluster_update_app
   :feature_category: :kubernetes_management
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: gcp_cluster:cluster_wait_for_app_update
   :feature_category: :kubernetes_management
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: geo:geo_batch_project_registry
   :feature_category: :geo_replication
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: geo:geo_batch_project_registry_scheduler
   :feature_category: :geo_replication
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: geo:geo_container_repository_sync
   :feature_category: :geo_replication
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: geo:geo_design_repository_shard_sync
   :feature_category: :geo_replication
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: geo:geo_design_repository_sync
   :feature_category: :geo_replication
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: geo:geo_event
   :feature_category: :geo_replication
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: geo:geo_file_download
   :feature_category: :geo_replication
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: geo:geo_file_registry_removal
   :feature_category: :geo_replication
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: geo:geo_file_removal
   :feature_category: :geo_replication
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: geo:geo_hashed_storage_attachments_migration
   :feature_category: :geo_replication
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: geo:geo_hashed_storage_migration
   :feature_category: :geo_replication
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: geo:geo_project_sync
   :feature_category: :geo_replication
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: geo:geo_rename_repository
   :feature_category: :geo_replication
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: geo:geo_repositories_clean_up
   :feature_category: :geo_replication
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: geo:geo_repository_cleanup
   :feature_category: :geo_replication
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: geo:geo_repository_destroy
   :feature_category: :geo_replication
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: geo:geo_repository_shard_sync
   :feature_category: :geo_replication
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: geo:geo_repository_verification_primary_shard
   :feature_category: :geo_replication
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: geo:geo_repository_verification_primary_single
   :feature_category: :geo_replication
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: geo:geo_repository_verification_secondary_single
   :feature_category: :geo_replication
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: geo:geo_scheduler_primary_scheduler
   :feature_category: :geo_replication
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: geo:geo_scheduler_scheduler
   :feature_category: :geo_replication
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: geo:geo_scheduler_secondary_scheduler
   :feature_category: :geo_replication
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: geo:geo_secondary_repository_backfill
   :feature_category: :geo_replication
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: incident_management:incident_management_process_prometheus_alert
   :feature_category: :incident_management
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :cpu
   :weight: 2
+  :idempotent: 
 - :name: jira_connect:jira_connect_sync_branch
   :feature_category: :integrations
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: jira_connect:jira_connect_sync_merge_request
   :feature_category: :integrations
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: package_repositories:packages_nuget_extraction
   :feature_category: :package_registry
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: personal_access_tokens:personal_access_tokens_policy
   :feature_category: :authentication_and_authorization
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: security_scans:store_security_reports
   :feature_category: :static_application_security_testing
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 2
+  :idempotent: 
 - :name: security_scans:store_security_scans
   :feature_category: :static_application_security_testing
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 2
+  :idempotent: 
 - :name: security_scans:sync_security_reports_to_report_approval_rules
   :feature_category: :static_application_security_testing
   :has_external_dependencies: 
   :latency_sensitive: true
   :resource_boundary: :cpu
   :weight: 2
+  :idempotent: 
 - :name: adjourned_project_deletion
   :feature_category: :authentication_and_authorization
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: admin_emails
   :feature_category: :issue_tracking
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: create_github_webhook
   :feature_category: :integrations
   :has_external_dependencies: true
   :latency_sensitive: 
   :resource_boundary: :cpu
   :weight: 2
+  :idempotent: 
 - :name: design_management_new_version
   :feature_category: :design_management
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: elastic_batch_project_indexer
   :feature_category: :search
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: elastic_commit_indexer
   :feature_category: :search
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: elastic_full_index
   :feature_category: :search
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: elastic_indexer
   :feature_category: :search
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: elastic_namespace_indexer
   :feature_category: :search
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: elastic_namespace_rollout
   :feature_category: :search
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: export_csv
   :feature_category: :issue_tracking
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :memory
   :weight: 1
+  :idempotent: 
 - :name: ldap_group_sync
   :feature_category: :authentication_and_authorization
   :has_external_dependencies: true
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 2
+  :idempotent: 
 - :name: new_epic
   :feature_category: :epics
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :cpu
   :weight: 2
+  :idempotent: 
 - :name: project_import_schedule
   :feature_category: :importers
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: project_update_repository_storage
   :feature_category: :source_code_management
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: refresh_license_compliance_checks
   :feature_category: :license_compliance
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 2
+  :idempotent: 
 - :name: repository_push_audit_event
   :feature_category: :authentication_and_authorization
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: repository_update_mirror
   :feature_category: :source_code_management
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 
 - :name: service_desk_email_receiver
   :feature_category: :issue_tracking
   :has_external_dependencies: 
   :latency_sensitive: 
   :resource_boundary: :unknown
   :weight: 1
+  :idempotent: 

ee/app/workers/clear_shared_runners_minutes_worker.rb

 # frozen_string_literal: true
 
-class ClearSharedRunnersMinutesWorker
+class ClearSharedRunnersMinutesWorker # rubocop:disable Scalability/IdempotentWorker
   LEASE_TIMEOUT = 3600
 
   include ApplicationWorker

ee/app/workers/cluster_update_app_worker.rb

 # frozen_string_literal: true
 
-class ClusterUpdateAppWorker
+class ClusterUpdateAppWorker # rubocop:disable Scalability/IdempotentWorker
   UpdateAlreadyInProgressError = Class.new(StandardError)
 
   include ApplicationWorker

ee/app/workers/cluster_wait_for_app_update_worker.rb

 # frozen_string_literal: true
 
-class ClusterWaitForAppUpdateWorker
+class ClusterWaitForAppUpdateWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include ClusterQueue
   include ClusterApplications

ee/app/workers/create_github_webhook_worker.rb

 # frozen_string_literal: true
 
-class CreateGithubWebhookWorker
+class CreateGithubWebhookWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include GrapePathHelpers::NamedRouteMatcher
 

ee/app/workers/design_management/new_version_worker.rb

 # frozen_string_literal: true
 
 module DesignManagement
-  class NewVersionWorker
+  class NewVersionWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
     feature_category :design_management

ee/app/workers/elastic_batch_project_indexer_worker.rb

 # frozen_string_literal: true
 
-class ElasticBatchProjectIndexerWorker
+class ElasticBatchProjectIndexerWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   feature_category :search

ee/app/workers/elastic_commit_indexer_worker.rb

 # frozen_string_literal: true
 
-class ElasticCommitIndexerWorker
+class ElasticCommitIndexerWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   feature_category :search

ee/app/workers/elastic_full_index_worker.rb

@@ -4,7 +4,7 @@
 # indexing the repository, wiki and its nested models
 # (e.g. )issues and notes etc.)
 # Intended for full site indexing.
-class ElasticFullIndexWorker
+class ElasticFullIndexWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   sidekiq_options retry: 2

ee/app/workers/elastic_indexer_worker.rb

 # frozen_string_literal: true
 
-class ElasticIndexerWorker
+class ElasticIndexerWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include Elasticsearch::Model::Client::ClassMethods
 

ee/app/workers/elastic_namespace_indexer_worker.rb

 # frozen_string_literal: true
 
-class ElasticNamespaceIndexerWorker
+class ElasticNamespaceIndexerWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   feature_category :search

ee/app/workers/elastic_namespace_rollout_worker.rb

 # frozen_string_literal: true
 
-class ElasticNamespaceRolloutWorker
+class ElasticNamespaceRolloutWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   feature_category :search

ee/app/workers/epics/update_epics_dates_worker.rb

 # frozen_string_literal: true
 
 module Epics
-  class UpdateEpicsDatesWorker
+  class UpdateEpicsDatesWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
     queue_namespace :epics

ee/app/workers/export_csv_worker.rb

 # frozen_string_literal: true
 
-class ExportCsvWorker
+class ExportCsvWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   feature_category :issue_tracking

ee/app/workers/geo/batch/project_registry_scheduler_worker.rb

@@ -6,7 +6,7 @@ module Geo
     #
     # This class includes an Exclusive Lease guard and only one can be executed at the same time
     # If multiple jobs are scheduled, only one will run and the others will drop forever.
-    class ProjectRegistrySchedulerWorker
+    class ProjectRegistrySchedulerWorker # rubocop:disable Scalability/IdempotentWorker
       include ApplicationWorker
       include GeoQueue
       include ExclusiveLeaseGuard

ee/app/workers/geo/batch/project_registry_worker.rb

@@ -6,7 +6,7 @@ module Geo
     #
     # This class includes an Exclusive Lease guard and only one can be executed at the same time
     # If multiple jobs are scheduled, only one will run and the others will drop forever.
-    class ProjectRegistryWorker
+    class ProjectRegistryWorker # rubocop:disable Scalability/IdempotentWorker
       include ApplicationWorker
       include GeoQueue
       include ::Gitlab::Geo::LogHelpers

ee/app/workers/geo/container_repository_sync_dispatch_worker.rb

 # frozen_string_literal: true
 
 module Geo
-  class ContainerRepositorySyncDispatchWorker < Geo::Scheduler::Secondary::SchedulerWorker
+  class ContainerRepositorySyncDispatchWorker < Geo::Scheduler::Secondary::SchedulerWorker # rubocop:disable Scalability/IdempotentWorker
     # rubocop:disable Scalability/CronWorkerContext
     # This worker does not perform work scoped to a context
     include CronjobQueue

ee/app/workers/geo/container_repository_sync_worker.rb

 # frozen_string_literal: true
 
 module Geo
-  class ContainerRepositorySyncWorker
+  class ContainerRepositorySyncWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
     include GeoQueue
     include Gitlab::Geo::LogHelpers

ee/app/workers/geo/design_repository_shard_sync_worker.rb

 # frozen_string_literal: true
 
 module Geo
-  class DesignRepositoryShardSyncWorker < RepositoryShardSyncWorker
+  class DesignRepositoryShardSyncWorker < RepositoryShardSyncWorker # rubocop:disable Scalability/IdempotentWorker
     private
 
     def schedule_job(project_id)

ee/app/workers/geo/design_repository_sync_worker.rb

 # frozen_string_literal: true
 
 module Geo
-  class DesignRepositorySyncWorker
+  class DesignRepositorySyncWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
     include GeoQueue
     include Gitlab::Geo::LogHelpers

ee/app/workers/geo/event_worker.rb

 # frozen_string_literal: true
 
 module Geo
-  class EventWorker
+  class EventWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
     include GeoQueue
 

ee/app/workers/geo/file_download_dispatch_worker.rb

 # frozen_string_literal: true
 
 module Geo
-  class FileDownloadDispatchWorker < Geo::Scheduler::Secondary::SchedulerWorker
+  class FileDownloadDispatchWorker < Geo::Scheduler::Secondary::SchedulerWorker # rubocop:disable Scalability/IdempotentWorker
     # rubocop:disable Scalability/CronWorkerContext
     # This worker does not perform work scoped to a context
     include CronjobQueue

ee/app/workers/geo/file_download_dispatch_worker/attachment_job_finder.rb

 # frozen_string_literal: true
 
 module Geo
-  class FileDownloadDispatchWorker
-    class AttachmentJobFinder < JobFinder
+  class FileDownloadDispatchWorker # rubocop:disable Scalability/IdempotentWorker
+    class AttachmentJobFinder < JobFinder # rubocop:disable Scalability/IdempotentWorker
       EXCEPT_RESOURCE_IDS_KEY = :except_file_ids
 
       def registry_finder

ee/app/workers/geo/file_download_dispatch_worker/job_artifact_job_finder.rb

 # frozen_string_literal: true
 
 module Geo
-  class FileDownloadDispatchWorker
-    class JobArtifactJobFinder < JobFinder
+  class FileDownloadDispatchWorker # rubocop:disable Scalability/IdempotentWorker
+    class JobArtifactJobFinder < JobFinder # rubocop:disable Scalability/IdempotentWorker
       RESOURCE_ID_KEY = :artifact_id
       EXCEPT_RESOURCE_IDS_KEY = :except_artifact_ids
       FILE_SERVICE_OBJECT_TYPE = :job_artifact

ee/app/workers/geo/file_download_dispatch_worker/job_finder.rb

 # frozen_string_literal: true
 
 module Geo
-  class FileDownloadDispatchWorker
+  class FileDownloadDispatchWorker # rubocop:disable Scalability/IdempotentWorker
     # This class is meant to be inherited, and is responsible for generating
     # batches of job arguments for FileDownloadWorker.
     #
@@ -12,7 +12,7 @@ module Geo
     #   * RESOURCE_ID_KEY
     #   * FILE_SERVICE_OBJECT_TYPE
     #
-    class JobFinder
+    class JobFinder # rubocop:disable Scalability/IdempotentWorker
       include Gitlab::Utils::StrongMemoize
 
       attr_reader :scheduled_file_ids

ee/app/workers/geo/file_download_dispatch_worker/lfs_object_job_finder.rb

 # frozen_string_literal: true
 
 module Geo
-  class FileDownloadDispatchWorker
-    class LfsObjectJobFinder < JobFinder
+  class FileDownloadDispatchWorker # rubocop:disable Scalability/IdempotentWorker
+    class LfsObjectJobFinder < JobFinder # rubocop:disable Scalability/IdempotentWorker
       RESOURCE_ID_KEY = :lfs_object_id
       EXCEPT_RESOURCE_IDS_KEY = :except_ids
       FILE_SERVICE_OBJECT_TYPE = :lfs

ee/app/workers/geo/file_download_worker.rb

 # frozen_string_literal: true
 
 module Geo
-  class FileDownloadWorker
+  class FileDownloadWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
     include GeoQueue
 

ee/app/workers/geo/file_registry_removal_worker.rb

 # frozen_string_literal: true
 
 module Geo
-  class FileRegistryRemovalWorker
+  class FileRegistryRemovalWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
     include GeoQueue
     include ::Gitlab::Geo::LogHelpers

ee/app/workers/geo/file_removal_worker.rb

 # frozen_string_literal: true
 
 module Geo
-  class FileRemovalWorker
+  class FileRemovalWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
     include Gitlab::Geo::LogHelpers
     include GeoQueue

ee/app/workers/geo/hashed_storage_attachments_migration_worker.rb

 # frozen_string_literal: true
 
 module Geo
-  class HashedStorageAttachmentsMigrationWorker
+  class HashedStorageAttachmentsMigrationWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
     include GeoQueue
 

ee/app/workers/geo/hashed_storage_migration_worker.rb

 # frozen_string_literal: true
 
 module Geo
-  class HashedStorageMigrationWorker
+  class HashedStorageMigrationWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
     include GeoQueue
 

ee/app/workers/geo/metrics_update_worker.rb

 # frozen_string_literal: true
 
 module Geo
-  class MetricsUpdateWorker
+  class MetricsUpdateWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
     include ExclusiveLeaseGuard
     # rubocop:disable Scalability/CronWorkerContext

ee/app/workers/geo/migrated_local_files_clean_up_worker.rb

 # frozen_string_literal: true
 
 module Geo
-  class MigratedLocalFilesCleanUpWorker < ::Geo::Scheduler::Secondary::SchedulerWorker
+  class MigratedLocalFilesCleanUpWorker < ::Geo::Scheduler::Secondary::SchedulerWorker # rubocop:disable Scalability/IdempotentWorker
     include ::CronjobQueue
 
     MAX_CAPACITY = 1000

ee/app/workers/geo/project_sync_worker.rb

 # frozen_string_literal: true
 
 module Geo
-  class ProjectSyncWorker
+  class ProjectSyncWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
     include GeoQueue
     include Gitlab::Geo::LogHelpers

ee/app/workers/geo/prune_event_log_worker.rb

 # frozen_string_literal: true
 
 module Geo
-  class PruneEventLogWorker
+  class PruneEventLogWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
     # rubocop:disable Scalability/CronWorkerContext
     # This worker does not perform work scoped to a context

ee/app/workers/geo/rename_repository_worker.rb

 # frozen_string_literal: true
 
 module Geo
-  class RenameRepositoryWorker
+  class RenameRepositoryWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
     include GeoQueue
 

ee/app/workers/geo/repositories_clean_up_worker.rb

 # frozen_string_literal: true
 
 module Geo
-  class RepositoriesCleanUpWorker
+  class RepositoriesCleanUpWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
     include ExclusiveLeaseGuard
     include GeoQueue

ee/app/workers/geo/repository_cleanup_worker.rb

 # frozen_string_literal: true
 
 module Geo
-  class RepositoryCleanupWorker
+  class RepositoryCleanupWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
     include GeoQueue
     include ::Gitlab::Geo::LogHelpers

ee/app/workers/geo/repository_shard_sync_worker.rb

 # frozen_string_literal: true
 
 module Geo
-  class RepositoryShardSyncWorker < Geo::Scheduler::Secondary::SchedulerWorker
+  class RepositoryShardSyncWorker < Geo::Scheduler::Secondary::SchedulerWorker # rubocop:disable Scalability/IdempotentWorker
     sidekiq_options retry: false
 
     attr_accessor :shard_name

ee/app/workers/geo/repository_sync_worker.rb

 # frozen_string_literal: true
 
 module Geo
-  class RepositorySyncWorker < Geo::Scheduler::Secondary::PerShardSchedulerWorker
+  class RepositorySyncWorker < Geo::Scheduler::Secondary::PerShardSchedulerWorker # rubocop:disable Scalability/IdempotentWorker
     def schedule_job(shard_name)
       if ::Feature.enabled?(:geo_streaming_results_repository_sync)
         Geo::Secondary::RepositoryBackfillWorker.perform_async(shard_name)

ee/app/workers/geo/repository_verification/primary/batch_worker.rb

@@ -3,7 +3,7 @@
 module Geo
   module RepositoryVerification
     module Primary
-      class BatchWorker < Geo::Scheduler::Primary::PerShardSchedulerWorker
+      class BatchWorker < Geo::Scheduler::Primary::PerShardSchedulerWorker # rubocop:disable Scalability/IdempotentWorker
         def perform
           return unless Gitlab::Geo.repository_verification_enabled?
 

ee/app/workers/geo/repository_verification/primary/shard_worker.rb

@@ -3,7 +3,7 @@
 module Geo
   module RepositoryVerification
     module Primary
-      class ShardWorker < Geo::Scheduler::Primary::SchedulerWorker
+      class ShardWorker < Geo::Scheduler::Primary::SchedulerWorker # rubocop:disable Scalability/IdempotentWorker
         sidekiq_options retry: false
 
         attr_accessor :shard_name

ee/app/workers/geo/repository_verification/primary/single_worker.rb

@@ -3,7 +3,7 @@
 module Geo
   module RepositoryVerification
     module Primary
-      class SingleWorker
+      class SingleWorker # rubocop:disable Scalability/IdempotentWorker
         include ApplicationWorker
         include GeoQueue
         include ExclusiveLeaseGuard

ee/app/workers/geo/repository_verification/secondary/scheduler_worker.rb

@@ -3,7 +3,7 @@
 module Geo
   module RepositoryVerification
     module Secondary
-      class SchedulerWorker < Geo::Scheduler::Secondary::PerShardSchedulerWorker
+      class SchedulerWorker < Geo::Scheduler::Secondary::PerShardSchedulerWorker # rubocop:disable Scalability/IdempotentWorker
         def perform
           return unless Gitlab::Geo.repository_verification_enabled?
 

ee/app/workers/geo/repository_verification/secondary/shard_worker.rb

@@ -3,7 +3,7 @@
 module Geo
   module RepositoryVerification
     module Secondary
-      class ShardWorker < Geo::Scheduler::Secondary::SchedulerWorker
+      class ShardWorker < Geo::Scheduler::Secondary::SchedulerWorker # rubocop:disable Scalability/IdempotentWorker
         # rubocop:disable Scalability/CronWorkerContext
         # This worker does not perform work scoped to a context
         include CronjobQueue

ee/app/workers/geo/repository_verification/secondary/single_worker.rb

@@ -3,7 +3,7 @@
 module Geo
   module RepositoryVerification
     module Secondary
-      class SingleWorker
+      class SingleWorker # rubocop:disable Scalability/IdempotentWorker
         include ApplicationWorker
         include GeoQueue
         include ExclusiveLeaseGuard

ee/app/workers/geo/scheduler/per_shard_scheduler_worker.rb

@@ -2,7 +2,7 @@
 
 module Geo
   module Scheduler
-    class PerShardSchedulerWorker
+    class PerShardSchedulerWorker # rubocop:disable Scalability/IdempotentWorker
       include ApplicationWorker
       # rubocop:disable Scalability/CronWorkerContext
       # This worker does not perform work scoped to a context

ee/app/workers/geo/scheduler/primary/per_shard_scheduler_worker.rb

@@ -3,7 +3,7 @@
 module Geo
   module Scheduler
     module Primary
-      class PerShardSchedulerWorker < Geo::Scheduler::PerShardSchedulerWorker
+      class PerShardSchedulerWorker < Geo::Scheduler::PerShardSchedulerWorker # rubocop:disable Scalability/IdempotentWorker
         def perform
           unless Gitlab::Geo.primary?
             log_info('Current node not a primary')

ee/app/workers/geo/scheduler/primary/scheduler_worker.rb

@@ -3,7 +3,7 @@
 module Geo
   module Scheduler
     module Primary
-      class SchedulerWorker < Geo::Scheduler::SchedulerWorker
+      class SchedulerWorker < Geo::Scheduler::SchedulerWorker # rubocop:disable Scalability/IdempotentWorker
         def perform
           return unless Gitlab::Geo.primary?
 

ee/app/workers/geo/scheduler/scheduler_worker.rb

@@ -2,7 +2,7 @@
 
 module Geo
   module Scheduler
-    class SchedulerWorker
+    class SchedulerWorker # rubocop:disable Scalability/IdempotentWorker
       include ApplicationWorker
       include GeoQueue
       include ExclusiveLeaseGuard

ee/app/workers/geo/scheduler/secondary/per_shard_scheduler_worker.rb

@@ -3,7 +3,7 @@
 module Geo
   module Scheduler
     module Secondary
-      class PerShardSchedulerWorker < Geo::Scheduler::PerShardSchedulerWorker
+      class PerShardSchedulerWorker < Geo::Scheduler::PerShardSchedulerWorker # rubocop:disable Scalability/IdempotentWorker
         def perform
           unless Gitlab::Geo.geo_database_configured?
             log_info('Geo database not configured')

ee/app/workers/geo/scheduler/secondary/scheduler_worker.rb

@@ -3,7 +3,7 @@
 module Geo
   module Scheduler
     module Secondary
-      class SchedulerWorker < Geo::Scheduler::SchedulerWorker
+      class SchedulerWorker < Geo::Scheduler::SchedulerWorker # rubocop:disable Scalability/IdempotentWorker
         def perform
           unless Gitlab::Geo.geo_database_configured?
             log_info('Geo database not configured')

ee/app/workers/geo/secondary/registry_consistency_worker.rb

@@ -5,7 +5,7 @@ module Geo
     # Iterates over syncable records and creates the corresponding registry
     # records which are missing. Then, the workers that actually schedule the
     # sync work only have to query the registry table for never-synced records.
-    class RegistryConsistencyWorker
+    class RegistryConsistencyWorker # rubocop:disable Scalability/IdempotentWorker
       include ApplicationWorker
       prepend Reenqueuer
       include ::Gitlab::Geo::LogHelpers

ee/app/workers/geo/secondary/repository_backfill_worker.rb

@@ -2,7 +2,7 @@
 
 module Geo
   module Secondary
-    class RepositoryBackfillWorker
+    class RepositoryBackfillWorker # rubocop:disable Scalability/IdempotentWorker
       include Geo::Secondary::BackfillWorker
 
       private

ee/app/workers/geo/sidekiq_cron_config_worker.rb

 # frozen_string_literal: true
 
 module Geo
-  class SidekiqCronConfigWorker
+  class SidekiqCronConfigWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
     # rubocop:disable Scalability/CronWorkerContext
     # This worker does not perform work scoped to a context

ee/app/workers/geo_repository_destroy_worker.rb

 # frozen_string_literal: true
 
-class GeoRepositoryDestroyWorker
+class GeoRepositoryDestroyWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include GeoQueue
 

ee/app/workers/historical_data_worker.rb

 # frozen_string_literal: true
 
-class HistoricalDataWorker
+class HistoricalDataWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   # rubocop:disable Scalability/CronWorkerContext
   # This worker does not perform work scoped to a context

ee/app/workers/import_software_licenses_worker.rb

 # frozen_string_literal: true
 
-class ImportSoftwareLicensesWorker
+class ImportSoftwareLicensesWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   queue_namespace :cronjob

ee/app/workers/incident_management/process_prometheus_alert_worker.rb

 # frozen_string_literal: true
 
 module IncidentManagement
-  class ProcessPrometheusAlertWorker
+  class ProcessPrometheusAlertWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
     queue_namespace :incident_management

ee/app/workers/jira_connect/sync_branch_worker.rb

 # frozen_string_literal: true
 
 module JiraConnect
-  class SyncBranchWorker
+  class SyncBranchWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
     queue_namespace :jira_connect

ee/app/workers/jira_connect/sync_merge_request_worker.rb

 # frozen_string_literal: true
 
 module JiraConnect
-  class SyncMergeRequestWorker
+  class SyncMergeRequestWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
     queue_namespace :jira_connect

ee/app/workers/ldap_all_groups_sync_worker.rb

 # frozen_string_literal: true
 
-class LdapAllGroupsSyncWorker
+class LdapAllGroupsSyncWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   # rubocop:disable Scalability/CronWorkerContext
   # This worker does not perform work scoped to a context

ee/app/workers/ldap_group_sync_worker.rb

 # frozen_string_literal: true
 
-class LdapGroupSyncWorker
+class LdapGroupSyncWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   feature_category :authentication_and_authorization

ee/app/workers/ldap_sync_worker.rb

 # frozen_string_literal: true
 
-class LdapSyncWorker
+class LdapSyncWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include CronjobQueue # rubocop:disable Scalability/CronWorkerContext
 

ee/app/workers/new_epic_worker.rb

 # frozen_string_literal: true
 
-class NewEpicWorker
+class NewEpicWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include NewIssuable
 

ee/app/workers/packages/nuget/extraction_worker.rb

@@ -2,7 +2,7 @@
 
 module Packages
   module Nuget
-    class ExtractionWorker
+    class ExtractionWorker # rubocop:disable Scalability/IdempotentWorker
       include ApplicationWorker
 
       queue_namespace :package_repositories

ee/app/workers/personal_access_tokens/policy_worker.rb

 # frozen_string_literal: true
 
 module PersonalAccessTokens
-  class PolicyWorker
+  class PolicyWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
     queue_namespace :personal_access_tokens

ee/app/workers/project_import_schedule_worker.rb

 # frozen_string_literal: true
 
-class ProjectImportScheduleWorker
+class ProjectImportScheduleWorker # rubocop:disable Scalability/IdempotentWorker
   ImportStateNotFound = Class.new(StandardError)
 
   include ApplicationWorker

ee/app/workers/project_update_repository_storage_worker.rb

 # frozen_string_literal: true
 
-class ProjectUpdateRepositoryStorageWorker
+class ProjectUpdateRepositoryStorageWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   feature_category :source_code_management

ee/app/workers/pseudonymizer_worker.rb

 # frozen_string_literal: true
 
-class PseudonymizerWorker
+class PseudonymizerWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   # rubocop:disable Scalability/CronWorkerContext
   # This worker does not perform work scoped to a context

ee/app/workers/refresh_license_compliance_checks_worker.rb

 # frozen_string_literal: true
 
-class RefreshLicenseComplianceChecksWorker
+class RefreshLicenseComplianceChecksWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   feature_category :license_compliance

ee/app/workers/repository_push_audit_event_worker.rb

 # frozen_string_literal: true
 
-class RepositoryPushAuditEventWorker
+class RepositoryPushAuditEventWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   feature_category :authentication_and_authorization

ee/app/workers/repository_update_mirror_worker.rb

 # frozen_string_literal: true
 
-class RepositoryUpdateMirrorWorker
+class RepositoryUpdateMirrorWorker # rubocop:disable Scalability/IdempotentWorker
   UpdateError = Class.new(StandardError)
 
   include ApplicationWorker

ee/app/workers/service_desk_email_receiver_worker.rb

 # frozen_string_literal: true
 
-class ServiceDeskEmailReceiverWorker < EmailReceiverWorker
+class ServiceDeskEmailReceiverWorker < EmailReceiverWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
   def perform(raw)

ee/app/workers/store_security_reports_worker.rb

@@ -2,7 +2,7 @@
 
 # Worker for storing security reports into the database.
 #
-class StoreSecurityReportsWorker
+class StoreSecurityReportsWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include SecurityScansQueue
 

ee/app/workers/store_security_scans_worker.rb

 # frozen_string_literal: true
 
-class StoreSecurityScansWorker
+class StoreSecurityScansWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include SecurityScansQueue
 

ee/app/workers/sync_security_reports_to_report_approval_rules_worker.rb

@@ -2,7 +2,7 @@
 
 # Worker for syncing report_type approval_rules approvals_required
 #
-class SyncSecurityReportsToReportApprovalRulesWorker
+class SyncSecurityReportsToReportApprovalRulesWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include SecurityScansQueue
 

ee/app/workers/update_all_mirrors_worker.rb

 # frozen_string_literal: true
 
-class UpdateAllMirrorsWorker
+class UpdateAllMirrorsWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include CronjobQueue
 

ee/app/workers/update_max_seats_used_for_gitlab_com_subscriptions_worker.rb

 # frozen_string_literal: true
 
-class UpdateMaxSeatsUsedForGitlabComSubscriptionsWorker
+class UpdateMaxSeatsUsedForGitlabComSubscriptionsWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
   include CronjobQueue # rubocop:disable Scalability/CronWorkerContext
 

lib/gitlab/sidekiq_config/dummy_worker.rb

@@ -11,6 +11,7 @@ module Gitlab
         has_external_dependencies: :worker_has_external_dependencies?,
         latency_sensitive: :latency_sensitive_worker?,
         resource_boundary: :get_worker_resource_boundary,
+        idempotent: :idempotent?,
         weight: :get_weight
       }.freeze
 

lib/gitlab/sidekiq_config/worker.rb

@@ -7,7 +7,7 @@ module Gitlab
 
       attr_reader :klass
       delegate :feature_category_not_owned?, :get_feature_category,
-               :get_weight, :get_worker_resource_boundary,
+               :get_weight, :get_worker_resource_boundary, :idempotent?,
                :latency_sensitive_worker?, :queue, :queue_namespace,
                :worker_has_external_dependencies?,
                to: :klass
@@ -51,7 +51,8 @@ module Gitlab
           has_external_dependencies: worker_has_external_dependencies?,
           latency_sensitive: latency_sensitive_worker?,
           resource_boundary: get_worker_resource_boundary,
-          weight: get_weight
+          weight: get_weight,
+          idempotent: idempotent?
         }
       end
 

rubocop/cop/scalability/idempotent_worker.rb

+# frozen_string_literal: true
+
+require_relative '../../code_reuse_helpers.rb'
+
+module RuboCop
+  module Cop
+    module Scalability
+      # This cop checks for the `idempotent!` call in the worker scope.
+      #
+      # @example
+      #
+      # # bad
+      # class TroubleMakerWorker
+      #   def perform
+      #   end
+      # end
+      #
+      # # good
+      # class NiceWorker
+      #   idempotent!
+      #
+      #   def perform
+      #   end
+      # end
+      #
+      class IdempotentWorker < RuboCop::Cop::Cop
+        include CodeReuseHelpers
+
+        HELP_LINK = 'https://github.com/mperham/sidekiq/wiki/Best-Practices#2-make-your-job-idempotent-and-transactional'
+
+        MSG = <<~MSG
+          Avoid adding not idempotent workers.
+
+          A worker is considered idempotent if:
+
+          1. It can safely run multiple times with the same arguments
+          2. The application side-effects are expected to happen once (or side-effects of a second run are not impactful)
+          3. It can safely be skipped if another job with the same arguments is already in the queue
+
+          If all the above is true, make sure to mark it as so by calling the `idempotent!`
+          method in the worker scope.
+
+          See #{HELP_LINK}
+        MSG
+
+        def_node_search :idempotent?, <<~PATTERN
+          (send nil? :idempotent!)
+        PATTERN
+
+        def on_class(node)
+          return unless in_worker?(node)
+          return if idempotent?(node)
+
+          add_offense(node, location: :expression)
+        end
+      end
+    end
+  end
+end

spec/lib/gitlab/sidekiq_config/worker_spec.rb

@@ -12,7 +12,8 @@ describe Gitlab::SidekiqConfig::Worker do
       get_weight: attributes[:weight],
       get_worker_resource_boundary: attributes[:resource_boundary],
       latency_sensitive_worker?: attributes[:latency_sensitive],
-      worker_has_external_dependencies?: attributes[:has_external_dependencies]
+      worker_has_external_dependencies?: attributes[:has_external_dependencies],
+      idempotent?: attributes[:idempotent]
     )
 
     described_class.new(inner_worker, ee: false)
@@ -89,7 +90,8 @@ describe Gitlab::SidekiqConfig::Worker do
         has_external_dependencies: false,
         latency_sensitive: false,
         resource_boundary: :memory,
-        weight: 2
+        weight: 2,
+        idempotent: true
       }
 
       attributes_b = {
@@ -97,7 +99,8 @@ describe Gitlab::SidekiqConfig::Worker do
         has_external_dependencies: true,
         latency_sensitive: true,
         resource_boundary: :unknown,
-        weight: 1
+        weight: 3,
+        idempotent: false
       }
 
       worker_a = create_worker(queue: 'a', **attributes_a)

spec/rubocop/cop/scalability/idempotent_worker_spec.rb

+# frozen_string_literal: true
+
+require 'fast_spec_helper'
+require 'rubocop'
+require_relative '../../../support/helpers/expect_offense'
+require_relative '../../../../rubocop/cop/scalability/idempotent_worker'
+
+describe RuboCop::Cop::Scalability::IdempotentWorker do
+  include CopHelper
+  include ExpectOffense
+
+  subject(:cop) { described_class.new }
+
+  before do
+    allow(cop)
+      .to receive(:in_worker?)
+      .and_return(true)
+  end
+
+  it 'adds an offense when not defining idempotent method' do
+    inspect_source(<<~CODE.strip_indent)
+      class SomeWorker
+      end
+    CODE
+
+    expect(cop.offenses.size).to eq(1)
+  end
+
+  it 'adds an offense when not defining idempotent method' do
+    inspect_source(<<~CODE.strip_indent)
+      class SomeWorker
+        idempotent!
+      end
+    CODE
+
+    expect(cop.offenses.size).to be_zero
+  end
+end

spec/spec_helper.rb

@@ -119,6 +119,7 @@ RSpec.configure do |config|
   config.include PolicyHelpers, type: :policy
   config.include MemoryUsageHelper
   config.include ExpectRequestWithStatus, type: :request
+  config.include IdempotentWorkerHelper, type: :worker
   config.include RailsHelpers
 
   if ENV['CI'] || ENV['RETRIES']

spec/support/helpers/idempotent_worker_helper.rb

+# frozen_string_literal: true
+
+module IdempotentWorkerHelper
+  WORKER_EXEC_TIMES = 2
+
+  def perform_multiple(args = [], worker: described_class.new, exec_times: WORKER_EXEC_TIMES)
+    Sidekiq::Testing.inline! do
+      job_args = args.nil? ? [nil] : Array.wrap(args)
+
+      expect(worker).to receive(:perform).exactly(exec_times).and_call_original
+
+      exec_times.times { worker.perform(*job_args) }
+    end
+  end
+end

spec/support/shared_examples/workers/idempotency_shared_examples.rb

+# frozen_string_literal: true
+
+# This shared_example requires the following variables:
+# - job_args (if not given, will fallback to call perform without arguments)
+#
+# Usage:
+#
+#   include_examples 'an idempotent worker' do
+#     it 'checks the side-effects for multiple calls' do
+#       # it'll call the job's perform method 3 times
+#       # by default.
+#       subject
+#
+#       expect(model.state).to eq('state')
+#     end
+#   end
+#
+RSpec.shared_examples 'an idempotent worker' do
+  # Avoid stubbing calls for a more accurate run.
+  subject do
+    defined?(job_args) ? perform_multiple(job_args) : perform_multiple
+  end
+
+  it 'is labeled as idempotent' do
+    expect(described_class).to be_idempotent
+  end
+
+  it 'performs multiple times sequentially without raising an exception' do
+    expect { subject }.not_to raise_error
+  end
+end

spec/workers/expire_job_cache_worker_spec.rb

@@ -6,20 +6,32 @@ describe ExpireJobCacheWorker do
   set(:pipeline) { create(:ci_empty_pipeline) }
   let(:project) { pipeline.project }
 
-  subject { described_class.new }
-
   describe '#perform' do
     context 'with a job in the pipeline' do
       let(:job) { create(:ci_build, pipeline: pipeline) }
+      let(:job_args) { job.id }
+
+      include_examples 'an idempotent worker' do
+        it 'invalidates Etag caching for the job path' do
+          pipeline_path = "/#{project.full_path}/pipelines/#{pipeline.id}.json"
+          job_path = "/#{project.full_path}/builds/#{job.id}.json"
+
+          spy_store = Gitlab::EtagCaching::Store.new
+
+          allow(Gitlab::EtagCaching::Store).to receive(:new) { spy_store }
 
-      it 'invalidates Etag caching for the job path' do
-        pipeline_path = "/#{project.full_path}/pipelines/#{pipeline.id}.json"
-        job_path = "/#{project.full_path}/builds/#{job.id}.json"
+          expect(spy_store).to receive(:touch)
+            .exactly(IdempotentWorkerHelper::WORKER_EXEC_TIMES).times
+            .with(pipeline_path)
+            .and_call_original
 
-        expect_any_instance_of(Gitlab::EtagCaching::Store).to receive(:touch).with(pipeline_path)
-        expect_any_instance_of(Gitlab::EtagCaching::Store).to receive(:touch).with(job_path)
+          expect(spy_store).to receive(:touch)
+            .exactly(IdempotentWorkerHelper::WORKER_EXEC_TIMES).times
+            .with(job_path)
+            .and_call_original
 
-        subject.perform(job.id)
+          subject
+        end
       end
     end
 
@@ -27,7 +39,7 @@ describe ExpireJobCacheWorker do
       it 'does not change the etag store' do
         expect(Gitlab::EtagCaching::Store).not_to receive(:new)
 
-        subject.perform(9999)
+        perform_multiple(9999)
       end
     end
   end