Merge branch '335170-fix-worker-data-consistency-offenses' into 'master'

Fix WorkerDataConsistency cop offenses [RUN AS-IF-FOSS] See merge request gitlab-org/gitlab!65427

Merge branch '335170-fix-worker-data-consistency-offenses' into 'master'
Fix WorkerDataConsistency cop offenses [RUN AS-IF-FOSS] See merge request gitlab-org/gitlab!65427
20bf82f5 · Alex Kalderimis · 350d973c · e49bea27 · 20bf82f5 · 20bf82f5
Commit 20bf82f5 authored Jul 21, 2021 by Alex Kalderimis
381 changed files
--- a/.rubocop_manual_todo.yml
+++ b/.rubocop_manual_todo.yml
--- a/app/workers/admin_email_worker.rb
+++ b/app/workers/admin_email_worker.rb
@@ -3,6 +3,8 @@
 class AdminEmailWorker # rubocop:disable Scalability/IdempotentWorker
  include ApplicationWorker
+  data_consistency :always
  sidekiq_options retry: 3
  # rubocop:disable Scalability/CronWorkerContext
  # This worker does not perform work scoped to a context

--- a/app/workers/analytics/usage_trends/count_job_trigger_worker.rb
+++ b/app/workers/analytics/usage_trends/count_job_trigger_worker.rb
@@ -6,6 +6,8 @@ module Analytics
      extend ::Gitlab::Utils::Override
      include ApplicationWorker
+      data_consistency :always
      sidekiq_options retry: 3
      include CronjobQueue # rubocop:disable Scalability/CronWorkerContext

--- a/app/workers/analytics/usage_trends/counter_job_worker.rb
+++ b/app/workers/analytics/usage_trends/counter_job_worker.rb
@@ -6,6 +6,8 @@ module Analytics
      extend ::Gitlab::Utils::Override
      include ApplicationWorker
+      data_consistency :always
      sidekiq_options retry: 3
      feature_category :devops_reports

--- a/app/workers/approve_blocked_pending_approval_users_worker.rb
+++ b/app/workers/approve_blocked_pending_approval_users_worker.rb
@@ -3,6 +3,8 @@
 class ApproveBlockedPendingApprovalUsersWorker
  include ApplicationWorker
+  data_consistency :always
  sidekiq_options retry: 3
  idempotent!

--- a/app/workers/authorized_keys_worker.rb
+++ b/app/workers/authorized_keys_worker.rb
@@ -3,6 +3,8 @@
 class AuthorizedKeysWorker
  include ApplicationWorker
+  data_consistency :always
  sidekiq_options retry: 3
  PERMITTED_ACTIONS = %w[add_key remove_key].freeze

--- a/app/workers/authorized_project_update/periodic_recalculate_worker.rb
+++ b/app/workers/authorized_project_update/periodic_recalculate_worker.rb
@@ -4,6 +4,8 @@ module AuthorizedProjectUpdate
  class PeriodicRecalculateWorker
    include ApplicationWorker
+    data_consistency :always
    sidekiq_options retry: 3
    # This worker does not perform work scoped to a context
    include CronjobQueue # rubocop:disable Scalability/CronWorkerContext

--- a/app/workers/authorized_project_update/project_create_worker.rb
+++ b/app/workers/authorized_project_update/project_create_worker.rb
@@ -4,6 +4,8 @@ module AuthorizedProjectUpdate
  class ProjectCreateWorker
    include ApplicationWorker
+    data_consistency :always
    sidekiq_options retry: 3
    feature_category :authentication_and_authorization

--- a/app/workers/authorized_project_update/project_group_link_create_worker.rb
+++ b/app/workers/authorized_project_update/project_group_link_create_worker.rb
@@ -4,6 +4,8 @@ module AuthorizedProjectUpdate
  class ProjectGroupLinkCreateWorker
    include ApplicationWorker
+    data_consistency :always
    sidekiq_options retry: 3
    feature_category :authentication_and_authorization

--- a/app/workers/authorized_project_update/project_recalculate_worker.rb
+++ b/app/workers/authorized_project_update/project_recalculate_worker.rb
@@ -3,6 +3,8 @@
 module AuthorizedProjectUpdate
  class ProjectRecalculateWorker
    include ApplicationWorker
+    data_consistency :always
    include Gitlab::ExclusiveLeaseHelpers
    feature_category :authentication_and_authorization

--- a/app/workers/authorized_project_update/user_refresh_from_replica_worker.rb
+++ b/app/workers/authorized_project_update/user_refresh_from_replica_worker.rb
@@ -7,6 +7,7 @@ module AuthorizedProjectUpdate
    sidekiq_options retry: 3
    feature_category :authentication_and_authorization
    urgency :low
+    data_consistency :always
    queue_namespace :authorized_project_update
    idempotent!

--- a/app/workers/authorized_projects_worker.rb
+++ b/app/workers/authorized_projects_worker.rb
@@ -3,6 +3,8 @@
 class AuthorizedProjectsWorker
  include ApplicationWorker
+  data_consistency :always
  sidekiq_options retry: 3
  prepend WaitableWorker

--- a/app/workers/auto_devops/disable_worker.rb
+++ b/app/workers/auto_devops/disable_worker.rb
@@ -4,6 +4,8 @@ module AutoDevops
  class DisableWorker # rubocop:disable Scalability/IdempotentWorker
    include ApplicationWorker
+    data_consistency :always
    sidekiq_options retry: 3
    include AutoDevopsQueue

--- a/app/workers/auto_merge_process_worker.rb
+++ b/app/workers/auto_merge_process_worker.rb
@@ -3,6 +3,8 @@
 class AutoMergeProcessWorker # rubocop:disable Scalability/IdempotentWorker
  include ApplicationWorker
+  data_consistency :always
  sidekiq_options retry: 3
  queue_namespace :auto_merge

--- a/app/workers/background_migration_worker.rb
+++ b/app/workers/background_migration_worker.rb
@@ -3,6 +3,8 @@
 class BackgroundMigrationWorker # rubocop:disable Scalability/IdempotentWorker
  include ApplicationWorker
+  data_consistency :always
  sidekiq_options retry: 3
  feature_category :database

--- a/app/workers/build_success_worker.rb
+++ b/app/workers/build_success_worker.rb
@@ -3,6 +3,8 @@
 class BuildSuccessWorker # rubocop:disable Scalability/IdempotentWorker
  include ApplicationWorker
+  data_consistency :always
  sidekiq_options retry: 3
  include PipelineQueue

--- a/app/workers/bulk_import_worker.rb
+++ b/app/workers/bulk_import_worker.rb
@@ -3,6 +3,8 @@
 class BulkImportWorker # rubocop:disable Scalability/IdempotentWorker
  include ApplicationWorker
+  data_consistency :always
  feature_category :importers
  tags :exclude_from_kubernetes

--- a/app/workers/bulk_imports/entity_worker.rb
+++ b/app/workers/bulk_imports/entity_worker.rb
@@ -4,6 +4,8 @@ module BulkImports
  class EntityWorker # rubocop:disable Scalability/IdempotentWorker
    include ApplicationWorker
+    data_consistency :always
    feature_category :importers
    tags :exclude_from_kubernetes

--- a/app/workers/bulk_imports/export_request_worker.rb
+++ b/app/workers/bulk_imports/export_request_worker.rb
@@ -4,6 +4,8 @@ module BulkImports
  class ExportRequestWorker
    include ApplicationWorker
+    data_consistency :always
    idempotent!
    worker_has_external_dependencies!
    feature_category :importers

--- a/app/workers/bulk_imports/pipeline_worker.rb
+++ b/app/workers/bulk_imports/pipeline_worker.rb
@@ -4,6 +4,8 @@ module BulkImports
  class PipelineWorker # rubocop:disable Scalability/IdempotentWorker
    include ApplicationWorker
+    data_consistency :always
    NDJSON_PIPELINE_PERFORM_DELAY = 1.minute
    feature_category :importers

--- a/app/workers/bulk_imports/relation_export_worker.rb
+++ b/app/workers/bulk_imports/relation_export_worker.rb
@@ -3,6 +3,8 @@
 module BulkImports
  class RelationExportWorker
    include ApplicationWorker
+    data_consistency :always
    include ExceptionBacktrace
    idempotent!

--- a/app/workers/chaos/cpu_spin_worker.rb
+++ b/app/workers/chaos/cpu_spin_worker.rb
@@ -4,6 +4,8 @@ module Chaos
  class CpuSpinWorker # rubocop:disable Scalability/IdempotentWorker
    include ApplicationWorker
+    data_consistency :always
    sidekiq_options retry: 3
    include ChaosQueue

--- a/app/workers/chaos/db_spin_worker.rb
+++ b/app/workers/chaos/db_spin_worker.rb
@@ -4,6 +4,8 @@ module Chaos
  class DbSpinWorker # rubocop:disable Scalability/IdempotentWorker
    include ApplicationWorker
+    data_consistency :always
    sidekiq_options retry: 3
    include ChaosQueue

--- a/app/workers/chaos/kill_worker.rb
+++ b/app/workers/chaos/kill_worker.rb
@@ -3,6 +3,8 @@
 module Chaos
  class KillWorker # rubocop:disable Scalability/IdempotentWorker
    include ApplicationWorker
+    data_consistency :always
    include ChaosQueue
    sidekiq_options retry: false

--- a/app/workers/chaos/leak_mem_worker.rb
+++ b/app/workers/chaos/leak_mem_worker.rb
@@ -4,6 +4,8 @@ module Chaos
  class LeakMemWorker # rubocop:disable Scalability/IdempotentWorker
    include ApplicationWorker
+    data_consistency :always
    sidekiq_options retry: 3
    include ChaosQueue

--- a/app/workers/chaos/sleep_worker.rb
+++ b/app/workers/chaos/sleep_worker.rb
@@ -4,6 +4,8 @@ module Chaos
  class SleepWorker # rubocop:disable Scalability/IdempotentWorker
    include ApplicationWorker
+    data_consistency :always
    sidekiq_options retry: 3
    include ChaosQueue

--- a/app/workers/chat_notification_worker.rb
+++ b/app/workers/chat_notification_worker.rb
@@ -3,6 +3,8 @@
 class ChatNotificationWorker # rubocop:disable Scalability/IdempotentWorker
  include ApplicationWorker
+  data_consistency :always
  TimeoutExceeded = Class.new(StandardError)
  sidekiq_options retry: false

--- a/app/workers/ci/archive_trace_worker.rb
+++ b/app/workers/ci/archive_trace_worker.rb
@@ -4,6 +4,8 @@ module Ci
  class ArchiveTraceWorker # rubocop:disable Scalability/IdempotentWorker
    include ApplicationWorker
+    data_consistency :always
    sidekiq_options retry: 3
    include PipelineBackgroundQueue

--- a/app/workers/ci/archive_traces_cron_worker.rb
+++ b/app/workers/ci/archive_traces_cron_worker.rb
@@ -4,6 +4,8 @@ module Ci
  class ArchiveTracesCronWorker # rubocop:disable Scalability/IdempotentWorker
    include ApplicationWorker
+    data_consistency :always
    sidekiq_options retry: 3
    include CronjobQueue # rubocop:disable Scalability/CronWorkerContext

--- a/app/workers/ci/build_finished_worker.rb
+++ b/app/workers/ci/build_finished_worker.rb
@@ -4,6 +4,8 @@ module Ci
  class BuildFinishedWorker # rubocop:disable Scalability/IdempotentWorker
    include ApplicationWorker
+    data_consistency :always
    sidekiq_options retry: 3
    include PipelineQueue

--- a/app/workers/ci/build_prepare_worker.rb
+++ b/app/workers/ci/build_prepare_worker.rb
@@ -4,6 +4,8 @@ module Ci
  class BuildPrepareWorker # rubocop:disable Scalability/IdempotentWorker
    include ApplicationWorker
+    data_consistency :always
    sidekiq_options retry: 3
    include PipelineQueue

--- a/app/workers/ci/build_schedule_worker.rb
+++ b/app/workers/ci/build_schedule_worker.rb
@@ -4,6 +4,8 @@ module Ci
  class BuildScheduleWorker # rubocop:disable Scalability/IdempotentWorker
    include ApplicationWorker
+    data_consistency :always
    sidekiq_options retry: 3
    include PipelineQueue

--- a/app/workers/ci/build_trace_chunk_flush_worker.rb
+++ b/app/workers/ci/build_trace_chunk_flush_worker.rb
@@ -4,6 +4,8 @@ module Ci
  class BuildTraceChunkFlushWorker
    include ApplicationWorker
+    data_consistency :always
    sidekiq_options retry: 3
    include PipelineBackgroundQueue

--- a/app/workers/ci/daily_build_group_report_results_worker.rb
+++ b/app/workers/ci/daily_build_group_report_results_worker.rb
@@ -4,6 +4,8 @@ module Ci
  class DailyBuildGroupReportResultsWorker
    include ApplicationWorker
+    data_consistency :always
    sidekiq_options retry: 3
    include PipelineBackgroundQueue

--- a/app/workers/ci/delete_objects_worker.rb
+++ b/app/workers/ci/delete_objects_worker.rb
@@ -4,6 +4,8 @@ module Ci
  class DeleteObjectsWorker
    include ApplicationWorker
+    data_consistency :always
    sidekiq_options retry: 3
    include LimitedCapacity::Worker

--- a/app/workers/ci/delete_unit_tests_worker.rb
+++ b/app/workers/ci/delete_unit_tests_worker.rb
@@ -3,6 +3,8 @@
 module Ci
  class DeleteUnitTestsWorker
    include ApplicationWorker
+    data_consistency :always
    # rubocop:disable Scalability/CronWorkerContext
    # This worker does not perform work scoped to a context
    include CronjobQueue

--- a/app/workers/ci/drop_pipeline_worker.rb
+++ b/app/workers/ci/drop_pipeline_worker.rb
@@ -4,6 +4,8 @@ module Ci
  class DropPipelineWorker
    include ApplicationWorker
+    data_consistency :always
    sidekiq_options retry: 3
    include PipelineQueue

--- a/app/workers/ci/initial_pipeline_process_worker.rb
+++ b/app/workers/ci/initial_pipeline_process_worker.rb
@@ -4,6 +4,8 @@ module Ci
  class InitialPipelineProcessWorker
    include ApplicationWorker
+    data_consistency :always
    sidekiq_options retry: 3
    include PipelineQueue

--- a/app/workers/ci/merge_requests/add_todo_when_build_fails_worker.rb
+++ b/app/workers/ci/merge_requests/add_todo_when_build_fails_worker.rb
@@ -4,6 +4,8 @@ module Ci
    class AddTodoWhenBuildFailsWorker
      include ApplicationWorker
+      data_consistency :always
      sidekiq_options retry: 3
      include PipelineQueue

--- a/app/workers/ci/pipeline_artifacts/coverage_report_worker.rb
+++ b/app/workers/ci/pipeline_artifacts/coverage_report_worker.rb
@@ -5,6 +5,8 @@ module Ci
    class CoverageReportWorker
      include ApplicationWorker
+      data_consistency :always
      sidekiq_options retry: 3
      include PipelineBackgroundQueue

--- a/app/workers/ci/pipeline_artifacts/create_quality_report_worker.rb
+++ b/app/workers/ci/pipeline_artifacts/create_quality_report_worker.rb
@@ -5,6 +5,8 @@ module Ci
    class CreateQualityReportWorker
      include ApplicationWorker
+      data_consistency :always
      sidekiq_options retry: 3
      queue_namespace :pipeline_background

--- a/app/workers/ci/pipeline_artifacts/expire_artifacts_worker.rb
+++ b/app/workers/ci/pipeline_artifacts/expire_artifacts_worker.rb
@@ -5,6 +5,8 @@ module Ci
    class ExpireArtifactsWorker
      include ApplicationWorker
+      data_consistency :always
      sidekiq_options retry: 3
      # rubocop:disable Scalability/CronWorkerContext
      # This worker does not perform work scoped to a context

--- a/app/workers/ci/pipeline_success_unlock_artifacts_worker.rb
+++ b/app/workers/ci/pipeline_success_unlock_artifacts_worker.rb
@@ -4,6 +4,8 @@ module Ci
  class PipelineSuccessUnlockArtifactsWorker
    include ApplicationWorker
+    data_consistency :always
    sidekiq_options retry: 3
    include PipelineBackgroundQueue

--- a/app/workers/ci/ref_delete_unlock_artifacts_worker.rb
+++ b/app/workers/ci/ref_delete_unlock_artifacts_worker.rb
@@ -4,6 +4,8 @@ module Ci
  class RefDeleteUnlockArtifactsWorker
    include ApplicationWorker
+    data_consistency :always
    sidekiq_options retry: 3
    include PipelineBackgroundQueue

--- a/app/workers/ci/resource_groups/assign_resource_from_resource_group_worker.rb
+++ b/app/workers/ci/resource_groups/assign_resource_from_resource_group_worker.rb
@@ -8,6 +8,8 @@ module Ci
    class AssignResourceFromResourceGroupWorker
      include ApplicationWorker
+      data_consistency :always
      sidekiq_options retry: 3
      include PipelineQueue

--- a/app/workers/ci/schedule_delete_objects_cron_worker.rb
+++ b/app/workers/ci/schedule_delete_objects_cron_worker.rb
@@ -4,6 +4,8 @@ module Ci
  class ScheduleDeleteObjectsCronWorker
    include ApplicationWorker
+    data_consistency :always
    sidekiq_options retry: 3
    # rubocop:disable Scalability/CronWorkerContext
    # This worker does not perform work scoped to a context

--- a/app/workers/ci/test_failure_history_worker.rb
+++ b/app/workers/ci/test_failure_history_worker.rb
@@ -4,6 +4,8 @@ module Ci
  class TestFailureHistoryWorker
    include ApplicationWorker
+    data_consistency :always
    sidekiq_options retry: 3
    include PipelineBackgroundQueue

--- a/app/workers/ci_platform_metrics_update_cron_worker.rb
+++ b/app/workers/ci_platform_metrics_update_cron_worker.rb
@@ -3,6 +3,8 @@
 class CiPlatformMetricsUpdateCronWorker # rubocop:disable Scalability/IdempotentWorker
  include ApplicationWorker
+  data_consistency :always
  sidekiq_options retry: 3
  # This worker does not perform work scoped to a context

--- a/app/workers/cleanup_container_repository_worker.rb
+++ b/app/workers/cleanup_container_repository_worker.rb
@@ -3,6 +3,8 @@
 class CleanupContainerRepositoryWorker
  include ApplicationWorker
+  data_consistency :always
  sidekiq_options retry: 3
  queue_namespace :container_repository

--- a/app/workers/cluster_configure_istio_worker.rb
+++ b/app/workers/cluster_configure_istio_worker.rb
@@ -3,6 +3,8 @@
 class ClusterConfigureIstioWorker # rubocop:disable Scalability/IdempotentWorker
  include ApplicationWorker
+  data_consistency :always
  sidekiq_options retry: 3
  include ClusterQueue

--- a/app/workers/cluster_install_app_worker.rb
+++ b/app/workers/cluster_install_app_worker.rb
@@ -3,6 +3,8 @@
 class ClusterInstallAppWorker # rubocop:disable Scalability/IdempotentWorker
  include ApplicationWorker
+  data_consistency :always
  sidekiq_options retry: 3
  include ClusterQueue
  include ClusterApplications

--- a/app/workers/cluster_patch_app_worker.rb
+++ b/app/workers/cluster_patch_app_worker.rb
@@ -3,6 +3,8 @@
 class ClusterPatchAppWorker # rubocop:disable Scalability/IdempotentWorker
  include ApplicationWorker
+  data_consistency :always
  sidekiq_options retry: 3
  include ClusterQueue
  include ClusterApplications

--- a/app/workers/cluster_provision_worker.rb
+++ b/app/workers/cluster_provision_worker.rb
@@ -3,6 +3,8 @@
 class ClusterProvisionWorker # rubocop:disable Scalability/IdempotentWorker
  include ApplicationWorker
+  data_consistency :always
  sidekiq_options retry: 3
  include ClusterQueue

--- a/app/workers/cluster_update_app_worker.rb
+++ b/app/workers/cluster_update_app_worker.rb
@@ -5,6 +5,8 @@ class ClusterUpdateAppWorker # rubocop:disable Scalability/IdempotentWorker
  UpdateAlreadyInProgressError = Class.new(StandardError)
  include ApplicationWorker
+  data_consistency :always
  include ClusterQueue
  include ClusterApplications
  include ExclusiveLeaseGuard

--- a/app/workers/cluster_upgrade_app_worker.rb
+++ b/app/workers/cluster_upgrade_app_worker.rb
@@ -3,6 +3,8 @@
 class ClusterUpgradeAppWorker # rubocop:disable Scalability/IdempotentWorker
  include ApplicationWorker
+  data_consistency :always
  sidekiq_options retry: 3
  include ClusterQueue
  include ClusterApplications

--- a/app/workers/cluster_wait_for_app_installation_worker.rb
+++ b/app/workers/cluster_wait_for_app_installation_worker.rb
@@ -3,6 +3,8 @@
 class ClusterWaitForAppInstallationWorker # rubocop:disable Scalability/IdempotentWorker
  include ApplicationWorker
+  data_consistency :always
  sidekiq_options retry: 3
  include ClusterQueue
  include ClusterApplications

--- a/app/workers/cluster_wait_for_app_update_worker.rb
+++ b/app/workers/cluster_wait_for_app_update_worker.rb
@@ -3,6 +3,8 @@
 class ClusterWaitForAppUpdateWorker # rubocop:disable Scalability/IdempotentWorker
  include ApplicationWorker
+  data_consistency :always
  sidekiq_options retry: 3
  include ClusterQueue
  include ClusterApplications

--- a/app/workers/cluster_wait_for_ingress_ip_address_worker.rb
+++ b/app/workers/cluster_wait_for_ingress_ip_address_worker.rb
@@ -3,6 +3,8 @@
 class ClusterWaitForIngressIpAddressWorker # rubocop:disable Scalability/IdempotentWorker
  include ApplicationWorker
+  data_consistency :always
  sidekiq_options retry: 3
  include ClusterQueue
  include ClusterApplications

--- a/app/workers/clusters/applications/activate_service_worker.rb
+++ b/app/workers/clusters/applications/activate_service_worker.rb
@@ -5,6 +5,8 @@ module Clusters
    class ActivateServiceWorker # rubocop:disable Scalability/IdempotentWorker
      include ApplicationWorker
+      data_consistency :always
      sidekiq_options retry: 3
      include ClusterQueue

--- a/app/workers/clusters/applications/check_prometheus_health_worker.rb
+++ b/app/workers/clusters/applications/check_prometheus_health_worker.rb
@@ -5,6 +5,8 @@ module Clusters
    class CheckPrometheusHealthWorker
      include ApplicationWorker
+      data_consistency :always
      sidekiq_options retry: 3
      # rubocop:disable Scalability/CronWorkerContext
      # This worker does not perform work scoped to a context

--- a/app/workers/clusters/applications/deactivate_service_worker.rb
+++ b/app/workers/clusters/applications/deactivate_service_worker.rb
@@ -5,6 +5,8 @@ module Clusters
    class DeactivateServiceWorker # rubocop:disable Scalability/IdempotentWorker
      include ApplicationWorker
+      data_consistency :always
      sidekiq_options retry: 3
      include ClusterQueue

--- a/app/workers/clusters/applications/uninstall_worker.rb
+++ b/app/workers/clusters/applications/uninstall_worker.rb
@@ -5,6 +5,8 @@ module Clusters
    class UninstallWorker # rubocop:disable Scalability/IdempotentWorker
      include ApplicationWorker
+      data_consistency :always
      sidekiq_options retry: 3
      include ClusterQueue
      include ClusterApplications

--- a/app/workers/clusters/applications/wait_for_uninstall_app_worker.rb
+++ b/app/workers/clusters/applications/wait_for_uninstall_app_worker.rb
@@ -5,6 +5,8 @@ module Clusters
    class WaitForUninstallAppWorker # rubocop:disable Scalability/IdempotentWorker
      include ApplicationWorker
+      data_consistency :always
      sidekiq_options retry: 3
      include ClusterQueue
      include ClusterApplications

--- a/app/workers/container_expiration_policies/cleanup_container_repository_worker.rb
+++ b/app/workers/container_expiration_policies/cleanup_container_repository_worker.rb
@@ -4,6 +4,8 @@ module ContainerExpirationPolicies
  class CleanupContainerRepositoryWorker
    include ApplicationWorker
+    data_consistency :always
    sidekiq_options retry: 3
    include LimitedCapacity::Worker
    include Gitlab::Utils::StrongMemoize

--- a/app/workers/container_expiration_policy_worker.rb
+++ b/app/workers/container_expiration_policy_worker.rb
@@ -3,6 +3,8 @@
 class ContainerExpirationPolicyWorker # rubocop:disable Scalability/IdempotentWorker
  include ApplicationWorker
+  data_consistency :always
  sidekiq_options retry: 3
  include CronjobQueue
  include ExclusiveLeaseGuard

--- a/app/workers/create_commit_signature_worker.rb
+++ b/app/workers/create_commit_signature_worker.rb
@@ -3,6 +3,8 @@
 class CreateCommitSignatureWorker
  include ApplicationWorker
+  data_consistency :always
  sidekiq_options retry: 3
  feature_category :source_code_management

--- a/app/workers/create_note_diff_file_worker.rb
+++ b/app/workers/create_note_diff_file_worker.rb
@@ -3,6 +3,8 @@
 class CreateNoteDiffFileWorker # rubocop:disable Scalability/IdempotentWorker
  include ApplicationWorker
+  data_consistency :always
  sidekiq_options retry: 3
  feature_category :code_review

--- a/app/workers/create_pipeline_worker.rb
+++ b/app/workers/create_pipeline_worker.rb
@@ -3,6 +3,8 @@
 class CreatePipelineWorker # rubocop:disable Scalability/IdempotentWorker
  include ApplicationWorker
+  data_consistency :always
  sidekiq_options retry: 3
  include PipelineQueue

--- a/app/workers/database/batched_background_migration_worker.rb
+++ b/app/workers/database/batched_background_migration_worker.rb
@@ -4,6 +4,8 @@ module Database
  class BatchedBackgroundMigrationWorker
    include ApplicationWorker
+    data_consistency :always
    sidekiq_options retry: 3
    include CronjobQueue # rubocop:disable Scalability/CronWorkerContext

--- a/app/workers/database/partition_management_worker.rb
+++ b/app/workers/database/partition_management_worker.rb
@@ -7,6 +7,8 @@ module Database
    sidekiq_options retry: 3
    include CronjobQueue # rubocop:disable Scalability/CronWorkerContext
+    data_consistency :always
    feature_category :database
    idempotent!

--- a/app/workers/delete_container_repository_worker.rb
+++ b/app/workers/delete_container_repository_worker.rb
@@ -3,6 +3,8 @@
 class DeleteContainerRepositoryWorker # rubocop:disable Scalability/IdempotentWorker
  include ApplicationWorker
+  data_consistency :always
  sidekiq_options retry: 3
  include ExclusiveLeaseGuard

--- a/app/workers/delete_diff_files_worker.rb
+++ b/app/workers/delete_diff_files_worker.rb
@@ -3,6 +3,8 @@
 class DeleteDiffFilesWorker # rubocop:disable Scalability/IdempotentWorker
  include ApplicationWorker
+  data_consistency :always
  sidekiq_options retry: 3
  feature_category :code_review

--- a/app/workers/delete_merged_branches_worker.rb
+++ b/app/workers/delete_merged_branches_worker.rb
@@ -3,6 +3,8 @@
 class DeleteMergedBranchesWorker # rubocop:disable Scalability/IdempotentWorker
  include ApplicationWorker
+  data_consistency :always
  sidekiq_options retry: 3
  feature_category :source_code_management

--- a/app/workers/delete_stored_files_worker.rb
+++ b/app/workers/delete_stored_files_worker.rb
@@ -3,6 +3,8 @@
 class DeleteStoredFilesWorker # rubocop:disable Scalability/IdempotentWorker
  include ApplicationWorker
+  data_consistency :always
  sidekiq_options retry: 3
  feature_category_not_owned!

--- a/app/workers/delete_user_worker.rb
+++ b/app/workers/delete_user_worker.rb
@@ -3,6 +3,8 @@
 class DeleteUserWorker # rubocop:disable Scalability/IdempotentWorker
  include ApplicationWorker
+  data_consistency :always
  sidekiq_options retry: 3
  feature_category :authentication_and_authorization

--- a/app/workers/deployments/drop_older_deployments_worker.rb
+++ b/app/workers/deployments/drop_older_deployments_worker.rb
@@ -4,6 +4,8 @@ module Deployments
  class DropOlderDeploymentsWorker # rubocop:disable Scalability/IdempotentWorker
    include ApplicationWorker
+    data_consistency :always
    sidekiq_options retry: 3
    queue_namespace :deployment

--- a/app/workers/deployments/finished_worker.rb
+++ b/app/workers/deployments/finished_worker.rb
@@ -6,6 +6,8 @@ module Deployments
  class FinishedWorker # rubocop:disable Scalability/IdempotentWorker
    include ApplicationWorker
+    data_consistency :always
    sidekiq_options retry: 3
    queue_namespace :deployment

--- a/app/workers/deployments/forward_deployment_worker.rb
+++ b/app/workers/deployments/forward_deployment_worker.rb
@@ -6,6 +6,8 @@ module Deployments
  class ForwardDeploymentWorker # rubocop:disable Scalability/IdempotentWorker
    include ApplicationWorker
+    data_consistency :always
    sidekiq_options retry: 3
    queue_namespace :deployment

--- a/app/workers/deployments/hooks_worker.rb
+++ b/app/workers/deployments/hooks_worker.rb
@@ -4,6 +4,8 @@ module Deployments
  class HooksWorker # rubocop:disable Scalability/IdempotentWorker
    include ApplicationWorker
+    data_consistency :always
    queue_namespace :deployment
    feature_category :continuous_delivery

--- a/app/workers/deployments/link_merge_request_worker.rb
+++ b/app/workers/deployments/link_merge_request_worker.rb
@@ -4,6 +4,8 @@ module Deployments
  class LinkMergeRequestWorker
    include ApplicationWorker
+    data_consistency :always
    sidekiq_options retry: 3
    queue_namespace :deployment

--- a/app/workers/deployments/success_worker.rb
+++ b/app/workers/deployments/success_worker.rb
@@ -6,6 +6,8 @@ module Deployments
  class SuccessWorker # rubocop:disable Scalability/IdempotentWorker
    include ApplicationWorker
+    data_consistency :always
    sidekiq_options retry: 3
    queue_namespace :deployment

--- a/app/workers/deployments/update_environment_worker.rb
+++ b/app/workers/deployments/update_environment_worker.rb
@@ -4,6 +4,8 @@ module Deployments
  class UpdateEnvironmentWorker
    include ApplicationWorker
+    data_consistency :always
    sidekiq_options retry: 3
    queue_namespace :deployment

--- a/app/workers/design_management/copy_design_collection_worker.rb
+++ b/app/workers/design_management/copy_design_collection_worker.rb
@@ -4,6 +4,8 @@ module DesignManagement
  class CopyDesignCollectionWorker
    include ApplicationWorker
+    data_consistency :always
    sidekiq_options retry: 3
    feature_category :design_management

--- a/app/workers/design_management/new_version_worker.rb
+++ b/app/workers/design_management/new_version_worker.rb
@@ -4,6 +4,8 @@ module DesignManagement
  class NewVersionWorker # rubocop:disable Scalability/IdempotentWorker
    include ApplicationWorker
+    data_consistency :always
    sidekiq_options retry: 3
    feature_category :design_management

--- a/app/workers/destroy_pages_deployments_worker.rb
+++ b/app/workers/destroy_pages_deployments_worker.rb
@@ -3,6 +3,8 @@
 class DestroyPagesDeploymentsWorker
  include ApplicationWorker
+  data_consistency :always
  idempotent!
  loggable_arguments 0, 1

--- a/app/workers/detect_repository_languages_worker.rb
+++ b/app/workers/detect_repository_languages_worker.rb
@@ -2,6 +2,8 @@
 class DetectRepositoryLanguagesWorker # rubocop:disable Scalability/IdempotentWorker
  include ApplicationWorker
+  data_consistency :always
  include ExceptionBacktrace
  include ExclusiveLeaseGuard

--- a/app/workers/disallow_two_factor_for_group_worker.rb
+++ b/app/workers/disallow_two_factor_for_group_worker.rb
@@ -3,6 +3,8 @@
 class DisallowTwoFactorForGroupWorker
  include ApplicationWorker
+  data_consistency :always
  sidekiq_options retry: 3
  include ExceptionBacktrace

--- a/app/workers/disallow_two_factor_for_subgroups_worker.rb
+++ b/app/workers/disallow_two_factor_for_subgroups_worker.rb
@@ -3,6 +3,8 @@
 class DisallowTwoFactorForSubgroupsWorker
  include ApplicationWorker
+  data_consistency :always
  sidekiq_options retry: 3
  include ExceptionBacktrace

--- a/app/workers/email_receiver_worker.rb
+++ b/app/workers/email_receiver_worker.rb
@@ -3,6 +3,8 @@
 class EmailReceiverWorker # rubocop:disable Scalability/IdempotentWorker
  include ApplicationWorker
+  data_consistency :always
  sidekiq_options retry: 3
  feature_category :issue_tracking

--- a/app/workers/emails_on_push_worker.rb
+++ b/app/workers/emails_on_push_worker.rb
@@ -3,6 +3,8 @@
 class EmailsOnPushWorker # rubocop:disable Scalability/IdempotentWorker
  include ApplicationWorker
+  data_consistency :always
  sidekiq_options retry: 3
  attr_reader :email, :skip_premailer

--- a/app/workers/environments/auto_stop_cron_worker.rb
+++ b/app/workers/environments/auto_stop_cron_worker.rb
@@ -4,6 +4,8 @@ module Environments
  class AutoStopCronWorker # rubocop:disable Scalability/IdempotentWorker
    include ApplicationWorker
+    data_consistency :always
    sidekiq_options retry: 3
    include CronjobQueue # rubocop:disable Scalability/CronWorkerContext

--- a/app/workers/environments/canary_ingress/update_worker.rb
+++ b/app/workers/environments/canary_ingress/update_worker.rb
@@ -5,6 +5,8 @@ module Environments
    class UpdateWorker
      include ApplicationWorker
+      data_consistency :always
      sidekiq_options retry: false
      idempotent!
      worker_has_external_dependencies!

--- a/app/workers/error_tracking_issue_link_worker.rb
+++ b/app/workers/error_tracking_issue_link_worker.rb
@@ -8,6 +8,8 @@
 class ErrorTrackingIssueLinkWorker # rubocop:disable Scalability/IdempotentWorker
  include ApplicationWorker
+  data_consistency :always
  sidekiq_options retry: 3
  include ExclusiveLeaseGuard
  include Gitlab::Utils::StrongMemoize

--- a/app/workers/experiments/record_conversion_event_worker.rb
+++ b/app/workers/experiments/record_conversion_event_worker.rb
@@ -4,6 +4,8 @@ module Experiments
  class RecordConversionEventWorker
    include ApplicationWorker
+    data_consistency :always
    sidekiq_options retry: 3
    feature_category :users

--- a/app/workers/expire_build_artifacts_worker.rb
+++ b/app/workers/expire_build_artifacts_worker.rb
@@ -3,6 +3,8 @@
 class ExpireBuildArtifactsWorker # rubocop:disable Scalability/IdempotentWorker
  include ApplicationWorker
+  data_consistency :always
  sidekiq_options retry: 3
  # rubocop:disable Scalability/CronWorkerContext
  # This worker does not perform work scoped to a context

--- a/app/workers/expire_build_instance_artifacts_worker.rb
+++ b/app/workers/expire_build_instance_artifacts_worker.rb
@@ -3,6 +3,8 @@
 class ExpireBuildInstanceArtifactsWorker # rubocop:disable Scalability/IdempotentWorker
  include ApplicationWorker
+  data_consistency :always
  sidekiq_options retry: 3
  feature_category :continuous_integration

--- a/app/workers/expire_job_cache_worker.rb
+++ b/app/workers/expire_job_cache_worker.rb
@@ -3,6 +3,8 @@
 class ExpireJobCacheWorker
  include ApplicationWorker
+  data_consistency :always
  sidekiq_options retry: 3
  include PipelineQueue

--- a/app/workers/export_csv_worker.rb
+++ b/app/workers/export_csv_worker.rb
@@ -3,6 +3,8 @@
 class ExportCsvWorker # rubocop:disable Scalability/IdempotentWorker
  include ApplicationWorker
+  data_consistency :always
  sidekiq_options retry: 3
  feature_category :issue_tracking

--- a/app/workers/file_hook_worker.rb
+++ b/app/workers/file_hook_worker.rb
@@ -3,6 +3,8 @@
 class FileHookWorker # rubocop:disable Scalability/IdempotentWorker
  include ApplicationWorker
+  data_consistency :always
  sidekiq_options retry: false
  feature_category :integrations
  loggable_arguments 0

--- a/app/workers/flush_counter_increments_worker.rb
+++ b/app/workers/flush_counter_increments_worker.rb
@@ -8,6 +8,8 @@
 class FlushCounterIncrementsWorker
  include ApplicationWorker
+  data_consistency :always
  sidekiq_options retry: 3
  feature_category_not_owned!

--- a/app/workers/gitlab/github_import/advance_stage_worker.rb
+++ b/app/workers/gitlab/github_import/advance_stage_worker.rb
--- a/app/workers/gitlab/github_import/refresh_import_jid_worker.rb
+++ b/app/workers/gitlab/github_import/refresh_import_jid_worker.rb
--- a/app/workers/gitlab/github_import/stage/finish_import_worker.rb
+++ b/app/workers/gitlab/github_import/stage/finish_import_worker.rb
--- a/app/workers/gitlab/github_import/stage/import_base_data_worker.rb
+++ b/app/workers/gitlab/github_import/stage/import_base_data_worker.rb
--- a/app/workers/gitlab/github_import/stage/import_issues_and_diff_notes_worker.rb
+++ b/app/workers/gitlab/github_import/stage/import_issues_and_diff_notes_worker.rb
--- a/app/workers/gitlab/github_import/stage/import_lfs_objects_worker.rb
+++ b/app/workers/gitlab/github_import/stage/import_lfs_objects_worker.rb
--- a/app/workers/gitlab/github_import/stage/import_notes_worker.rb
+++ b/app/workers/gitlab/github_import/stage/import_notes_worker.rb
--- a/app/workers/gitlab/github_import/stage/import_pull_requests_merged_by_worker.rb
+++ b/app/workers/gitlab/github_import/stage/import_pull_requests_merged_by_worker.rb
--- a/app/workers/gitlab/github_import/stage/import_pull_requests_reviews_worker.rb
+++ b/app/workers/gitlab/github_import/stage/import_pull_requests_reviews_worker.rb
--- a/app/workers/gitlab/github_import/stage/import_pull_requests_worker.rb
+++ b/app/workers/gitlab/github_import/stage/import_pull_requests_worker.rb
--- a/app/workers/gitlab/github_import/stage/import_repository_worker.rb
+++ b/app/workers/gitlab/github_import/stage/import_repository_worker.rb
--- a/app/workers/gitlab/jira_import/advance_stage_worker.rb
+++ b/app/workers/gitlab/jira_import/advance_stage_worker.rb
--- a/app/workers/gitlab/jira_import/import_issue_worker.rb
+++ b/app/workers/gitlab/jira_import/import_issue_worker.rb
--- a/app/workers/gitlab/jira_import/stage/start_import_worker.rb
+++ b/app/workers/gitlab/jira_import/stage/start_import_worker.rb
--- a/app/workers/gitlab/phabricator_import/import_tasks_worker.rb
+++ b/app/workers/gitlab/phabricator_import/import_tasks_worker.rb
--- a/app/workers/gitlab_performance_bar_stats_worker.rb
+++ b/app/workers/gitlab_performance_bar_stats_worker.rb
--- a/app/workers/gitlab_service_ping_worker.rb
+++ b/app/workers/gitlab_service_ping_worker.rb
--- a/app/workers/gitlab_shell_worker.rb
+++ b/app/workers/gitlab_shell_worker.rb
--- a/app/workers/group_destroy_worker.rb
+++ b/app/workers/group_destroy_worker.rb
--- a/app/workers/group_export_worker.rb
+++ b/app/workers/group_export_worker.rb
--- a/app/workers/group_import_worker.rb
+++ b/app/workers/group_import_worker.rb
--- a/app/workers/hashed_storage/migrator_worker.rb
+++ b/app/workers/hashed_storage/migrator_worker.rb
--- a/app/workers/hashed_storage/project_migrate_worker.rb
+++ b/app/workers/hashed_storage/project_migrate_worker.rb
--- a/app/workers/hashed_storage/project_rollback_worker.rb
+++ b/app/workers/hashed_storage/project_rollback_worker.rb
--- a/app/workers/hashed_storage/rollbacker_worker.rb
+++ b/app/workers/hashed_storage/rollbacker_worker.rb
--- a/app/workers/import_export_project_cleanup_worker.rb
+++ b/app/workers/import_export_project_cleanup_worker.rb
--- a/app/workers/import_issues_csv_worker.rb
+++ b/app/workers/import_issues_csv_worker.rb
--- a/app/workers/incident_management/add_severity_system_note_worker.rb
+++ b/app/workers/incident_management/add_severity_system_note_worker.rb
--- a/app/workers/incident_management/pager_duty/process_incident_worker.rb
+++ b/app/workers/incident_management/pager_duty/process_incident_worker.rb
--- a/app/workers/incident_management/process_alert_worker_v2.rb
+++ b/app/workers/incident_management/process_alert_worker_v2.rb
--- a/app/workers/invalid_gpg_signature_update_worker.rb
+++ b/app/workers/invalid_gpg_signature_update_worker.rb
--- a/app/workers/irker_worker.rb
+++ b/app/workers/irker_worker.rb
--- a/app/workers/issuable/label_links_destroy_worker.rb
+++ b/app/workers/issuable/label_links_destroy_worker.rb
--- a/app/workers/issuable_export_csv_worker.rb
+++ b/app/workers/issuable_export_csv_worker.rb
--- a/app/workers/issuables/clear_groups_issue_counter_worker.rb
+++ b/app/workers/issuables/clear_groups_issue_counter_worker.rb
--- a/app/workers/issue_due_scheduler_worker.rb
+++ b/app/workers/issue_due_scheduler_worker.rb
--- a/app/workers/issue_placement_worker.rb
+++ b/app/workers/issue_placement_worker.rb
--- a/app/workers/issue_rebalancing_worker.rb
+++ b/app/workers/issue_rebalancing_worker.rb
--- a/app/workers/jira_connect/forward_event_worker.rb
+++ b/app/workers/jira_connect/forward_event_worker.rb
--- a/app/workers/mail_scheduler/issue_due_worker.rb
+++ b/app/workers/mail_scheduler/issue_due_worker.rb
--- a/app/workers/mail_scheduler/notification_service_worker.rb
+++ b/app/workers/mail_scheduler/notification_service_worker.rb
--- a/app/workers/member_invitation_reminder_emails_worker.rb
+++ b/app/workers/member_invitation_reminder_emails_worker.rb
--- a/app/workers/members_destroyer/unassign_issuables_worker.rb
+++ b/app/workers/members_destroyer/unassign_issuables_worker.rb
--- a/app/workers/merge_request_cleanup_refs_worker.rb
+++ b/app/workers/merge_request_cleanup_refs_worker.rb
--- a/app/workers/merge_request_mergeability_check_worker.rb
+++ b/app/workers/merge_request_mergeability_check_worker.rb
--- a/app/workers/merge_requests/create_pipeline_worker.rb
+++ b/app/workers/merge_requests/create_pipeline_worker.rb
--- a/app/workers/merge_requests/delete_source_branch_worker.rb
+++ b/app/workers/merge_requests/delete_source_branch_worker.rb
--- a/app/workers/merge_requests/handle_assignees_change_worker.rb
+++ b/app/workers/merge_requests/handle_assignees_change_worker.rb
--- a/app/workers/merge_requests/resolve_todos_worker.rb
+++ b/app/workers/merge_requests/resolve_todos_worker.rb
--- a/app/workers/merge_worker.rb
+++ b/app/workers/merge_worker.rb
--- a/app/workers/metrics/dashboard/prune_old_annotations_worker.rb
+++ b/app/workers/metrics/dashboard/prune_old_annotations_worker.rb
--- a/app/workers/metrics/dashboard/schedule_annotations_prune_worker.rb
+++ b/app/workers/metrics/dashboard/schedule_annotations_prune_worker.rb
--- a/app/workers/metrics/dashboard/sync_dashboards_worker.rb
+++ b/app/workers/metrics/dashboard/sync_dashboards_worker.rb
--- a/app/workers/migrate_external_diffs_worker.rb
+++ b/app/workers/migrate_external_diffs_worker.rb
--- a/app/workers/namespaceless_project_destroy_worker.rb
+++ b/app/workers/namespaceless_project_destroy_worker.rb
--- a/app/workers/namespaces/in_product_marketing_emails_worker.rb
+++ b/app/workers/namespaces/in_product_marketing_emails_worker.rb
--- a/app/workers/namespaces/onboarding_issue_created_worker.rb
+++ b/app/workers/namespaces/onboarding_issue_created_worker.rb
--- a/app/workers/namespaces/onboarding_pipeline_created_worker.rb
+++ b/app/workers/namespaces/onboarding_pipeline_created_worker.rb
--- a/app/workers/namespaces/onboarding_progress_worker.rb
+++ b/app/workers/namespaces/onboarding_progress_worker.rb
--- a/app/workers/namespaces/onboarding_user_added_worker.rb
+++ b/app/workers/namespaces/onboarding_user_added_worker.rb
--- a/app/workers/namespaces/prune_aggregation_schedules_worker.rb
+++ b/app/workers/namespaces/prune_aggregation_schedules_worker.rb
--- a/app/workers/namespaces/root_statistics_worker.rb
+++ b/app/workers/namespaces/root_statistics_worker.rb
--- a/app/workers/namespaces/schedule_aggregation_worker.rb
+++ b/app/workers/namespaces/schedule_aggregation_worker.rb
--- a/app/workers/new_issue_worker.rb
+++ b/app/workers/new_issue_worker.rb
--- a/app/workers/new_merge_request_worker.rb
+++ b/app/workers/new_merge_request_worker.rb
--- a/app/workers/new_note_worker.rb
+++ b/app/workers/new_note_worker.rb
--- a/app/workers/object_pool/create_worker.rb
+++ b/app/workers/object_pool/create_worker.rb
--- a/app/workers/object_pool/destroy_worker.rb
+++ b/app/workers/object_pool/destroy_worker.rb
--- a/app/workers/object_pool/join_worker.rb
+++ b/app/workers/object_pool/join_worker.rb
--- a/app/workers/object_pool/schedule_join_worker.rb
+++ b/app/workers/object_pool/schedule_join_worker.rb
--- a/app/workers/object_storage/background_move_worker.rb
+++ b/app/workers/object_storage/background_move_worker.rb
--- a/app/workers/object_storage/migrate_uploads_worker.rb
+++ b/app/workers/object_storage/migrate_uploads_worker.rb
--- a/app/workers/packages/composer/cache_cleanup_worker.rb
+++ b/app/workers/packages/composer/cache_cleanup_worker.rb
--- a/app/workers/packages/composer/cache_update_worker.rb
+++ b/app/workers/packages/composer/cache_update_worker.rb
--- a/app/workers/packages/debian/generate_distribution_worker.rb
+++ b/app/workers/packages/debian/generate_distribution_worker.rb
--- a/app/workers/packages/debian/process_changes_worker.rb
+++ b/app/workers/packages/debian/process_changes_worker.rb
--- a/app/workers/packages/go/sync_packages_worker.rb
+++ b/app/workers/packages/go/sync_packages_worker.rb
--- a/app/workers/packages/helm/extraction_worker.rb
+++ b/app/workers/packages/helm/extraction_worker.rb
--- a/app/workers/packages/maven/metadata/sync_worker.rb
+++ b/app/workers/packages/maven/metadata/sync_worker.rb
--- a/app/workers/packages/nuget/extraction_worker.rb
+++ b/app/workers/packages/nuget/extraction_worker.rb
--- a/app/workers/packages/rubygems/extraction_worker.rb
+++ b/app/workers/packages/rubygems/extraction_worker.rb
--- a/app/workers/pages_domain_removal_cron_worker.rb
+++ b/app/workers/pages_domain_removal_cron_worker.rb
--- a/app/workers/pages_domain_ssl_renewal_cron_worker.rb
+++ b/app/workers/pages_domain_ssl_renewal_cron_worker.rb
--- a/app/workers/pages_domain_ssl_renewal_worker.rb
+++ b/app/workers/pages_domain_ssl_renewal_worker.rb
--- a/app/workers/pages_domain_verification_cron_worker.rb
+++ b/app/workers/pages_domain_verification_cron_worker.rb
--- a/app/workers/pages_domain_verification_worker.rb
+++ b/app/workers/pages_domain_verification_worker.rb
--- a/app/workers/pages_remove_worker.rb
+++ b/app/workers/pages_remove_worker.rb
--- a/app/workers/pages_transfer_worker.rb
+++ b/app/workers/pages_transfer_worker.rb
--- a/app/workers/pages_update_configuration_worker.rb
+++ b/app/workers/pages_update_configuration_worker.rb
--- a/app/workers/pages_worker.rb
+++ b/app/workers/pages_worker.rb
--- a/app/workers/partition_creation_worker.rb
+++ b/app/workers/partition_creation_worker.rb
--- a/app/workers/personal_access_tokens/expired_notification_worker.rb
+++ b/app/workers/personal_access_tokens/expired_notification_worker.rb
--- a/app/workers/personal_access_tokens/expiring_worker.rb
+++ b/app/workers/personal_access_tokens/expiring_worker.rb
--- a/app/workers/pipeline_metrics_worker.rb
+++ b/app/workers/pipeline_metrics_worker.rb
--- a/app/workers/pipeline_notification_worker.rb
+++ b/app/workers/pipeline_notification_worker.rb
--- a/app/workers/pipeline_process_worker.rb
+++ b/app/workers/pipeline_process_worker.rb
--- a/app/workers/pipeline_schedule_worker.rb
+++ b/app/workers/pipeline_schedule_worker.rb
--- a/app/workers/post_receive.rb
+++ b/app/workers/post_receive.rb
--- a/app/workers/process_commit_worker.rb
+++ b/app/workers/process_commit_worker.rb
--- a/app/workers/project_cache_worker.rb
+++ b/app/workers/project_cache_worker.rb
--- a/app/workers/project_daily_statistics_worker.rb
+++ b/app/workers/project_daily_statistics_worker.rb
--- a/app/workers/project_destroy_worker.rb
+++ b/app/workers/project_destroy_worker.rb
--- a/app/workers/project_export_worker.rb
+++ b/app/workers/project_export_worker.rb
--- a/app/workers/project_service_worker.rb
+++ b/app/workers/project_service_worker.rb
--- a/app/workers/projects/post_creation_worker.rb
+++ b/app/workers/projects/post_creation_worker.rb
--- a/app/workers/projects/schedule_bulk_repository_shard_moves_worker.rb
+++ b/app/workers/projects/schedule_bulk_repository_shard_moves_worker.rb
--- a/app/workers/prometheus/create_default_alerts_worker.rb
+++ b/app/workers/prometheus/create_default_alerts_worker.rb
--- a/app/workers/propagate_integration_group_worker.rb
+++ b/app/workers/propagate_integration_group_worker.rb
--- a/app/workers/propagate_integration_inherit_descendant_worker.rb
+++ b/app/workers/propagate_integration_inherit_descendant_worker.rb
--- a/app/workers/propagate_integration_inherit_worker.rb
+++ b/app/workers/propagate_integration_inherit_worker.rb
--- a/app/workers/propagate_integration_project_worker.rb
+++ b/app/workers/propagate_integration_project_worker.rb
--- a/app/workers/propagate_integration_worker.rb
+++ b/app/workers/propagate_integration_worker.rb
--- a/app/workers/propagate_service_template_worker.rb
+++ b/app/workers/propagate_service_template_worker.rb
--- a/app/workers/prune_old_events_worker.rb
+++ b/app/workers/prune_old_events_worker.rb
--- a/app/workers/purge_dependency_proxy_cache_worker.rb
+++ b/app/workers/purge_dependency_proxy_cache_worker.rb
--- a/app/workers/rebase_worker.rb
+++ b/app/workers/rebase_worker.rb
--- a/app/workers/releases/create_evidence_worker.rb
+++ b/app/workers/releases/create_evidence_worker.rb
--- a/app/workers/releases/manage_evidence_worker.rb
+++ b/app/workers/releases/manage_evidence_worker.rb
--- a/app/workers/remote_mirror_notification_worker.rb
+++ b/app/workers/remote_mirror_notification_worker.rb
--- a/app/workers/remove_expired_group_links_worker.rb
+++ b/app/workers/remove_expired_group_links_worker.rb
--- a/app/workers/remove_expired_members_worker.rb
+++ b/app/workers/remove_expired_members_worker.rb
--- a/app/workers/remove_unaccepted_member_invites_worker.rb
+++ b/app/workers/remove_unaccepted_member_invites_worker.rb
--- a/app/workers/remove_unreferenced_lfs_objects_worker.rb
+++ b/app/workers/remove_unreferenced_lfs_objects_worker.rb
--- a/app/workers/repository_archive_cache_worker.rb
+++ b/app/workers/repository_archive_cache_worker.rb
--- a/app/workers/repository_check/batch_worker.rb
+++ b/app/workers/repository_check/batch_worker.rb
--- a/app/workers/repository_check/clear_worker.rb
+++ b/app/workers/repository_check/clear_worker.rb
--- a/app/workers/repository_check/dispatch_worker.rb
+++ b/app/workers/repository_check/dispatch_worker.rb
--- a/app/workers/repository_check/single_repository_worker.rb
+++ b/app/workers/repository_check/single_repository_worker.rb
--- a/app/workers/repository_cleanup_worker.rb
+++ b/app/workers/repository_cleanup_worker.rb
--- a/app/workers/repository_fork_worker.rb
+++ b/app/workers/repository_fork_worker.rb
--- a/app/workers/repository_import_worker.rb
+++ b/app/workers/repository_import_worker.rb
--- a/app/workers/repository_remove_remote_worker.rb
+++ b/app/workers/repository_remove_remote_worker.rb
--- a/app/workers/repository_update_remote_mirror_worker.rb
+++ b/app/workers/repository_update_remote_mirror_worker.rb
--- a/app/workers/requests_profiles_worker.rb
+++ b/app/workers/requests_profiles_worker.rb
--- a/app/workers/run_pipeline_schedule_worker.rb
+++ b/app/workers/run_pipeline_schedule_worker.rb
--- a/app/workers/schedule_merge_request_cleanup_refs_worker.rb
+++ b/app/workers/schedule_merge_request_cleanup_refs_worker.rb
--- a/app/workers/schedule_migrate_external_diffs_worker.rb
+++ b/app/workers/schedule_migrate_external_diffs_worker.rb
--- a/app/workers/self_monitoring_project_create_worker.rb
+++ b/app/workers/self_monitoring_project_create_worker.rb
--- a/app/workers/self_monitoring_project_delete_worker.rb
+++ b/app/workers/self_monitoring_project_delete_worker.rb
--- a/app/workers/service_desk_email_receiver_worker.rb
+++ b/app/workers/service_desk_email_receiver_worker.rb
--- a/app/workers/snippets/schedule_bulk_repository_shard_moves_worker.rb
+++ b/app/workers/snippets/schedule_bulk_repository_shard_moves_worker.rb
--- a/app/workers/ssh_keys/expired_notification_worker.rb
+++ b/app/workers/ssh_keys/expired_notification_worker.rb
--- a/app/workers/ssh_keys/expiring_soon_notification_worker.rb
+++ b/app/workers/ssh_keys/expiring_soon_notification_worker.rb
--- a/app/workers/stage_update_worker.rb
+++ b/app/workers/stage_update_worker.rb
--- a/app/workers/stuck_ci_jobs_worker.rb
+++ b/app/workers/stuck_ci_jobs_worker.rb
--- a/app/workers/stuck_export_jobs_worker.rb
+++ b/app/workers/stuck_export_jobs_worker.rb
--- a/app/workers/stuck_merge_jobs_worker.rb
+++ b/app/workers/stuck_merge_jobs_worker.rb
--- a/app/workers/system_hook_push_worker.rb
+++ b/app/workers/system_hook_push_worker.rb
--- a/app/workers/todos_destroyer/confidential_issue_worker.rb
+++ b/app/workers/todos_destroyer/confidential_issue_worker.rb
--- a/app/workers/todos_destroyer/destroyed_issuable_worker.rb
+++ b/app/workers/todos_destroyer/destroyed_issuable_worker.rb
--- a/app/workers/todos_destroyer/entity_leave_worker.rb
+++ b/app/workers/todos_destroyer/entity_leave_worker.rb
--- a/app/workers/todos_destroyer/group_private_worker.rb
+++ b/app/workers/todos_destroyer/group_private_worker.rb
--- a/app/workers/todos_destroyer/private_features_worker.rb
+++ b/app/workers/todos_destroyer/private_features_worker.rb
--- a/app/workers/todos_destroyer/project_private_worker.rb
+++ b/app/workers/todos_destroyer/project_private_worker.rb
--- a/app/workers/trending_projects_worker.rb
+++ b/app/workers/trending_projects_worker.rb
--- a/app/workers/update_container_registry_info_worker.rb
+++ b/app/workers/update_container_registry_info_worker.rb
--- a/app/workers/update_external_pull_requests_worker.rb
+++ b/app/workers/update_external_pull_requests_worker.rb
--- a/app/workers/update_head_pipeline_for_merge_request_worker.rb
+++ b/app/workers/update_head_pipeline_for_merge_request_worker.rb
--- a/app/workers/update_highest_role_worker.rb
+++ b/app/workers/update_highest_role_worker.rb
--- a/app/workers/update_merge_requests_worker.rb
+++ b/app/workers/update_merge_requests_worker.rb
--- a/app/workers/update_project_statistics_worker.rb
+++ b/app/workers/update_project_statistics_worker.rb
--- a/app/workers/upload_checksum_worker.rb
+++ b/app/workers/upload_checksum_worker.rb
--- a/app/workers/user_status_cleanup/batch_worker.rb
+++ b/app/workers/user_status_cleanup/batch_worker.rb
--- a/app/workers/users/create_statistics_worker.rb
+++ b/app/workers/users/create_statistics_worker.rb
--- a/app/workers/users/deactivate_dormant_users_worker.rb
+++ b/app/workers/users/deactivate_dormant_users_worker.rb
--- a/app/workers/wait_for_cluster_creation_worker.rb
+++ b/app/workers/wait_for_cluster_creation_worker.rb
--- a/app/workers/web_hooks/destroy_worker.rb
+++ b/app/workers/web_hooks/destroy_worker.rb
--- a/app/workers/web_hooks/log_execution_worker.rb
+++ b/app/workers/web_hooks/log_execution_worker.rb
--- a/app/workers/x509_certificate_revoke_worker.rb
+++ b/app/workers/x509_certificate_revoke_worker.rb
--- a/app/workers/x509_issuer_crl_check_worker.rb
+++ b/app/workers/x509_issuer_crl_check_worker.rb
--- a/ee/app/workers/active_user_count_threshold_worker.rb
+++ b/ee/app/workers/active_user_count_threshold_worker.rb
--- a/ee/app/workers/adjourned_group_deletion_worker.rb
+++ b/ee/app/workers/adjourned_group_deletion_worker.rb
--- a/ee/app/workers/adjourned_project_deletion_worker.rb
+++ b/ee/app/workers/adjourned_project_deletion_worker.rb
--- a/ee/app/workers/adjourned_projects_deletion_cron_worker.rb
+++ b/ee/app/workers/adjourned_projects_deletion_cron_worker.rb
--- a/ee/app/workers/admin_emails_worker.rb
+++ b/ee/app/workers/admin_emails_worker.rb
--- a/ee/app/workers/analytics/code_review_metrics_worker.rb
+++ b/ee/app/workers/analytics/code_review_metrics_worker.rb
--- a/ee/app/workers/analytics/devops_adoption/create_all_snapshots_worker.rb
+++ b/ee/app/workers/analytics/devops_adoption/create_all_snapshots_worker.rb
--- a/ee/app/workers/analytics/devops_adoption/create_snapshot_worker.rb
+++ b/ee/app/workers/analytics/devops_adoption/create_snapshot_worker.rb
--- a/ee/app/workers/approval_rules/external_approval_rule_payload_worker.rb
+++ b/ee/app/workers/approval_rules/external_approval_rule_payload_worker.rb
--- a/ee/app/workers/ci/batch_reset_minutes_worker.rb
+++ b/ee/app/workers/ci/batch_reset_minutes_worker.rb
--- a/ee/app/workers/ci/sync_reports_to_report_approval_rules_worker.rb
+++ b/ee/app/workers/ci/sync_reports_to_report_approval_rules_worker.rb
--- a/ee/app/workers/clear_shared_runners_minutes_worker.rb
+++ b/ee/app/workers/clear_shared_runners_minutes_worker.rb
--- a/ee/app/workers/create_github_webhook_worker.rb
+++ b/ee/app/workers/create_github_webhook_worker.rb
--- a/ee/app/workers/dast_site_validation_worker.rb
+++ b/ee/app/workers/dast_site_validation_worker.rb
--- a/ee/app/workers/deployments/auto_rollback_worker.rb
+++ b/ee/app/workers/deployments/auto_rollback_worker.rb
--- a/ee/app/workers/dora/daily_metrics/refresh_worker.rb
+++ b/ee/app/workers/dora/daily_metrics/refresh_worker.rb
--- a/ee/app/workers/elastic/migration_worker.rb
+++ b/ee/app/workers/elastic/migration_worker.rb
--- a/ee/app/workers/elastic_association_indexer_worker.rb
+++ b/ee/app/workers/elastic_association_indexer_worker.rb
--- a/ee/app/workers/elastic_cluster_reindexing_cron_worker.rb
+++ b/ee/app/workers/elastic_cluster_reindexing_cron_worker.rb
--- a/ee/app/workers/elastic_commit_indexer_worker.rb
+++ b/ee/app/workers/elastic_commit_indexer_worker.rb
--- a/ee/app/workers/elastic_delete_project_worker.rb
+++ b/ee/app/workers/elastic_delete_project_worker.rb
--- a/ee/app/workers/elastic_full_index_worker.rb
+++ b/ee/app/workers/elastic_full_index_worker.rb
--- a/ee/app/workers/elastic_indexing_control_worker.rb
+++ b/ee/app/workers/elastic_indexing_control_worker.rb
--- a/ee/app/workers/elastic_namespace_indexer_worker.rb
+++ b/ee/app/workers/elastic_namespace_indexer_worker.rb
--- a/ee/app/workers/elastic_namespace_rollout_worker.rb
+++ b/ee/app/workers/elastic_namespace_rollout_worker.rb
--- a/ee/app/workers/elastic_remove_expired_namespace_subscriptions_from_index_cron_worker.rb
+++ b/ee/app/workers/elastic_remove_expired_namespace_subscriptions_from_index_cron_worker.rb
--- a/ee/app/workers/epics/new_epic_issue_worker.rb
+++ b/ee/app/workers/epics/new_epic_issue_worker.rb
--- a/ee/app/workers/epics/update_epics_dates_worker.rb
+++ b/ee/app/workers/epics/update_epics_dates_worker.rb
--- a/ee/app/workers/geo/batch/project_registry_scheduler_worker.rb
+++ b/ee/app/workers/geo/batch/project_registry_scheduler_worker.rb
--- a/ee/app/workers/geo/batch/project_registry_worker.rb
+++ b/ee/app/workers/geo/batch/project_registry_worker.rb
--- a/ee/app/workers/geo/container_repository_sync_worker.rb
+++ b/ee/app/workers/geo/container_repository_sync_worker.rb
--- a/ee/app/workers/geo/design_repository_sync_worker.rb
+++ b/ee/app/workers/geo/design_repository_sync_worker.rb
--- a/ee/app/workers/geo/destroy_worker.rb
+++ b/ee/app/workers/geo/destroy_worker.rb
--- a/ee/app/workers/geo/event_worker.rb
+++ b/ee/app/workers/geo/event_worker.rb
--- a/ee/app/workers/geo/file_download_worker.rb
+++ b/ee/app/workers/geo/file_download_worker.rb
--- a/ee/app/workers/geo/file_registry_removal_worker.rb
+++ b/ee/app/workers/geo/file_registry_removal_worker.rb
--- a/ee/app/workers/geo/file_removal_worker.rb
+++ b/ee/app/workers/geo/file_removal_worker.rb
--- a/ee/app/workers/geo/hashed_storage_attachments_migration_worker.rb
+++ b/ee/app/workers/geo/hashed_storage_attachments_migration_worker.rb
--- a/ee/app/workers/geo/hashed_storage_migration_worker.rb
+++ b/ee/app/workers/geo/hashed_storage_migration_worker.rb
--- a/ee/app/workers/geo/metrics_update_worker.rb
+++ b/ee/app/workers/geo/metrics_update_worker.rb
--- a/ee/app/workers/geo/project_sync_worker.rb
+++ b/ee/app/workers/geo/project_sync_worker.rb
--- a/ee/app/workers/geo/prune_event_log_worker.rb
+++ b/ee/app/workers/geo/prune_event_log_worker.rb
--- a/ee/app/workers/geo/rename_repository_worker.rb
+++ b/ee/app/workers/geo/rename_repository_worker.rb
--- a/ee/app/workers/geo/repositories_clean_up_worker.rb
+++ b/ee/app/workers/geo/repositories_clean_up_worker.rb
--- a/ee/app/workers/geo/repository_cleanup_worker.rb
+++ b/ee/app/workers/geo/repository_cleanup_worker.rb
--- a/ee/app/workers/geo/repository_verification/primary/single_worker.rb
+++ b/ee/app/workers/geo/repository_verification/primary/single_worker.rb
--- a/ee/app/workers/geo/repository_verification/secondary/single_worker.rb
+++ b/ee/app/workers/geo/repository_verification/secondary/single_worker.rb
--- a/ee/app/workers/geo/reverification_batch_worker.rb
+++ b/ee/app/workers/geo/reverification_batch_worker.rb
--- a/ee/app/workers/geo/scheduler/per_shard_scheduler_worker.rb
+++ b/ee/app/workers/geo/scheduler/per_shard_scheduler_worker.rb
--- a/ee/app/workers/geo/scheduler/scheduler_worker.rb
+++ b/ee/app/workers/geo/scheduler/scheduler_worker.rb
--- a/ee/app/workers/geo/secondary/registry_consistency_worker.rb
+++ b/ee/app/workers/geo/secondary/registry_consistency_worker.rb
--- a/ee/app/workers/geo/secondary_usage_data_cron_worker.rb
+++ b/ee/app/workers/geo/secondary_usage_data_cron_worker.rb
--- a/ee/app/workers/geo/sidekiq_cron_config_worker.rb
+++ b/ee/app/workers/geo/sidekiq_cron_config_worker.rb
--- a/ee/app/workers/geo/sync_timeout_cron_worker.rb
+++ b/ee/app/workers/geo/sync_timeout_cron_worker.rb
--- a/ee/app/workers/geo/verification_batch_worker.rb
+++ b/ee/app/workers/geo/verification_batch_worker.rb
--- a/ee/app/workers/geo/verification_cron_worker.rb
+++ b/ee/app/workers/geo/verification_cron_worker.rb
--- a/ee/app/workers/geo/verification_timeout_worker.rb
+++ b/ee/app/workers/geo/verification_timeout_worker.rb
--- a/ee/app/workers/geo/verification_worker.rb
+++ b/ee/app/workers/geo/verification_worker.rb
--- a/ee/app/workers/geo_repository_destroy_worker.rb
+++ b/ee/app/workers/geo_repository_destroy_worker.rb
--- a/ee/app/workers/group_saml_group_sync_worker.rb
+++ b/ee/app/workers/group_saml_group_sync_worker.rb
--- a/ee/app/workers/groups/schedule_bulk_repository_shard_moves_worker.rb
+++ b/ee/app/workers/groups/schedule_bulk_repository_shard_moves_worker.rb
--- a/ee/app/workers/groups/update_statistics_worker.rb
+++ b/ee/app/workers/groups/update_statistics_worker.rb
--- a/ee/app/workers/historical_data_worker.rb
+++ b/ee/app/workers/historical_data_worker.rb
--- a/ee/app/workers/import_software_licenses_worker.rb
+++ b/ee/app/workers/import_software_licenses_worker.rb
--- a/ee/app/workers/incident_management/apply_incident_sla_exceeded_label_worker.rb
+++ b/ee/app/workers/incident_management/apply_incident_sla_exceeded_label_worker.rb
--- a/ee/app/workers/incident_management/incident_sla_exceeded_check_worker.rb
+++ b/ee/app/workers/incident_management/incident_sla_exceeded_check_worker.rb
--- a/ee/app/workers/incident_management/oncall_rotations/persist_all_rotations_shifts_job.rb
+++ b/ee/app/workers/incident_management/oncall_rotations/persist_all_rotations_shifts_job.rb
--- a/ee/app/workers/incident_management/oncall_rotations/persist_shifts_job.rb
+++ b/ee/app/workers/incident_management/oncall_rotations/persist_shifts_job.rb
--- a/ee/app/workers/incident_management/pending_escalations/alert_check_worker.rb
+++ b/ee/app/workers/incident_management/pending_escalations/alert_check_worker.rb
--- a/ee/app/workers/incident_management/pending_escalations/alert_create_worker.rb
+++ b/ee/app/workers/incident_management/pending_escalations/alert_create_worker.rb
--- a/ee/app/workers/incident_management/pending_escalations/schedule_check_cron_worker.rb
+++ b/ee/app/workers/incident_management/pending_escalations/schedule_check_cron_worker.rb
--- a/ee/app/workers/iterations/cadences/create_iterations_worker.rb
+++ b/ee/app/workers/iterations/cadences/create_iterations_worker.rb
--- a/ee/app/workers/iterations/cadences/schedule_create_iterations_worker.rb
+++ b/ee/app/workers/iterations/cadences/schedule_create_iterations_worker.rb
--- a/ee/app/workers/iterations/roll_over_issues_worker.rb
+++ b/ee/app/workers/iterations/roll_over_issues_worker.rb
--- a/ee/app/workers/iterations_update_status_worker.rb
+++ b/ee/app/workers/iterations_update_status_worker.rb
--- a/ee/app/workers/ldap_all_groups_sync_worker.rb
+++ b/ee/app/workers/ldap_all_groups_sync_worker.rb
--- a/ee/app/workers/ldap_group_sync_worker.rb
+++ b/ee/app/workers/ldap_group_sync_worker.rb
--- a/ee/app/workers/ldap_sync_worker.rb
+++ b/ee/app/workers/ldap_sync_worker.rb
--- a/ee/app/workers/merge_request_reset_approvals_worker.rb
+++ b/ee/app/workers/merge_request_reset_approvals_worker.rb
--- a/ee/app/workers/merge_requests/sync_code_owner_approval_rules_worker.rb
+++ b/ee/app/workers/merge_requests/sync_code_owner_approval_rules_worker.rb
--- a/ee/app/workers/merge_trains/refresh_worker.rb
+++ b/ee/app/workers/merge_trains/refresh_worker.rb
--- a/ee/app/workers/network_policy_metrics_worker.rb
+++ b/ee/app/workers/network_policy_metrics_worker.rb
--- a/ee/app/workers/new_epic_worker.rb
+++ b/ee/app/workers/new_epic_worker.rb
--- a/ee/app/workers/personal_access_tokens/groups/policy_worker.rb
+++ b/ee/app/workers/personal_access_tokens/groups/policy_worker.rb
--- a/ee/app/workers/personal_access_tokens/instance/policy_worker.rb
+++ b/ee/app/workers/personal_access_tokens/instance/policy_worker.rb
--- a/ee/app/workers/project_import_schedule_worker.rb
+++ b/ee/app/workers/project_import_schedule_worker.rb
--- a/ee/app/workers/pseudonymizer_worker.rb
+++ b/ee/app/workers/pseudonymizer_worker.rb
--- a/ee/app/workers/refresh_license_compliance_checks_worker.rb
+++ b/ee/app/workers/refresh_license_compliance_checks_worker.rb
--- a/ee/app/workers/repository_push_audit_event_worker.rb
+++ b/ee/app/workers/repository_push_audit_event_worker.rb
--- a/ee/app/workers/repository_update_mirror_worker.rb
+++ b/ee/app/workers/repository_update_mirror_worker.rb
--- a/ee/app/workers/requirements_management/import_requirements_csv_worker.rb
+++ b/ee/app/workers/requirements_management/import_requirements_csv_worker.rb
--- a/ee/app/workers/requirements_management/process_requirements_reports_worker.rb
+++ b/ee/app/workers/requirements_management/process_requirements_reports_worker.rb
--- a/ee/app/workers/scan_security_report_secrets_worker.rb
+++ b/ee/app/workers/scan_security_report_secrets_worker.rb
--- a/ee/app/workers/security/auto_fix_worker.rb
+++ b/ee/app/workers/security/auto_fix_worker.rb
--- a/ee/app/workers/security/create_orchestration_policy_worker.rb
+++ b/ee/app/workers/security/create_orchestration_policy_worker.rb
--- a/ee/app/workers/security/orchestration_policy_rule_schedule_worker.rb
+++ b/ee/app/workers/security/orchestration_policy_rule_schedule_worker.rb
--- a/ee/app/workers/security/store_scans_worker.rb
+++ b/ee/app/workers/security/store_scans_worker.rb
--- a/ee/app/workers/security/track_secure_scans_worker.rb
+++ b/ee/app/workers/security/track_secure_scans_worker.rb
--- a/ee/app/workers/set_user_status_based_on_user_cap_setting_worker.rb
+++ b/ee/app/workers/set_user_status_based_on_user_cap_setting_worker.rb
--- a/ee/app/workers/status_page/publish_worker.rb
+++ b/ee/app/workers/status_page/publish_worker.rb
--- a/ee/app/workers/store_security_reports_worker.rb
+++ b/ee/app/workers/store_security_reports_worker.rb
--- a/ee/app/workers/store_security_scans_worker.rb
+++ b/ee/app/workers/store_security_scans_worker.rb
--- a/ee/app/workers/sync_seat_link_request_worker.rb
+++ b/ee/app/workers/sync_seat_link_request_worker.rb
--- a/ee/app/workers/sync_seat_link_worker.rb
+++ b/ee/app/workers/sync_seat_link_worker.rb
--- a/ee/app/workers/todos_destroyer/confidential_epic_worker.rb
+++ b/ee/app/workers/todos_destroyer/confidential_epic_worker.rb
--- a/ee/app/workers/update_max_seats_used_for_gitlab_com_subscriptions_worker.rb
+++ b/ee/app/workers/update_max_seats_used_for_gitlab_com_subscriptions_worker.rb
--- a/ee/app/workers/vulnerabilities/historical_statistics/deletion_worker.rb
+++ b/ee/app/workers/vulnerabilities/historical_statistics/deletion_worker.rb
--- a/ee/app/workers/vulnerabilities/statistics/adjustment_worker.rb
+++ b/ee/app/workers/vulnerabilities/statistics/adjustment_worker.rb
--- a/ee/app/workers/vulnerabilities/statistics/schedule_worker.rb
+++ b/ee/app/workers/vulnerabilities/statistics/schedule_worker.rb
--- a/ee/app/workers/vulnerability_exports/export_deletion_worker.rb
+++ b/ee/app/workers/vulnerability_exports/export_deletion_worker.rb
--- a/ee/app/workers/vulnerability_exports/export_worker.rb
+++ b/ee/app/workers/vulnerability_exports/export_worker.rb