Fix existing WorkerDataConsistency cop offenses

This cop was introduced in:
https://gitlab.com/gitlab-org/gitlab/-/merge_requests/65341

.rubocop_manual_todo.yml

@@ -3024,397 +3024,3 @@ Database/MultipleDatabases:
     - 'spec/tasks/gitlab/db_rake_spec.rb'
     - 'spec/workers/analytics/usage_trends/counter_job_worker_spec.rb'
     - 'spec/workers/users/create_statistics_worker_spec.rb'
-
-# See https://gitlab.com/gitlab-org/gitlab/-/issues/335170
-Cop/WorkerDataConsistency:
-  Exclude:
-    - 'app/workers/admin_email_worker.rb'
-    - 'app/workers/analytics/usage_trends/count_job_trigger_worker.rb'
-    - 'app/workers/analytics/usage_trends/counter_job_worker.rb'
-    - 'app/workers/approve_blocked_pending_approval_users_worker.rb'
-    - 'app/workers/archive_trace_worker.rb'
-    - 'app/workers/authorized_keys_worker.rb'
-    - 'app/workers/authorized_project_update/periodic_recalculate_worker.rb'
-    - 'app/workers/authorized_project_update/project_create_worker.rb'
-    - 'app/workers/authorized_project_update/project_group_link_create_worker.rb'
-    - 'app/workers/authorized_project_update/project_recalculate_worker.rb'
-    - 'app/workers/authorized_project_update/user_refresh_from_replica_worker.rb'
-    - 'app/workers/authorized_projects_worker.rb'
-    - 'app/workers/auto_devops/disable_worker.rb'
-    - 'app/workers/auto_merge_process_worker.rb'
-    - 'app/workers/background_migration_worker.rb'
-    - 'app/workers/build_finished_worker.rb'
-    - 'app/workers/build_success_worker.rb'
-    - 'app/workers/bulk_import_worker.rb'
-    - 'app/workers/bulk_imports/entity_worker.rb'
-    - 'app/workers/bulk_imports/export_request_worker.rb'
-    - 'app/workers/bulk_imports/pipeline_worker.rb'
-    - 'app/workers/bulk_imports/relation_export_worker.rb'
-    - 'app/workers/chaos/cpu_spin_worker.rb'
-    - 'app/workers/chaos/db_spin_worker.rb'
-    - 'app/workers/chaos/kill_worker.rb'
-    - 'app/workers/chaos/leak_mem_worker.rb'
-    - 'app/workers/chaos/sleep_worker.rb'
-    - 'app/workers/chat_notification_worker.rb'
-    - 'app/workers/ci/archive_trace_worker.rb'
-    - 'app/workers/ci/archive_traces_cron_worker.rb'
-    - 'app/workers/ci/build_finished_worker.rb'
-    - 'app/workers/ci/build_prepare_worker.rb'
-    - 'app/workers/ci/build_schedule_worker.rb'
-    - 'app/workers/ci/build_trace_chunk_flush_worker.rb'
-    - 'app/workers/ci/daily_build_group_report_results_worker.rb'
-    - 'app/workers/ci/delete_objects_worker.rb'
-    - 'app/workers/ci/delete_unit_tests_worker.rb'
-    - 'app/workers/ci/drop_pipeline_worker.rb'
-    - 'app/workers/ci/initial_pipeline_process_worker.rb'
-    - 'app/workers/ci/merge_requests/add_todo_when_build_fails_worker.rb'
-    - 'app/workers/ci/pipeline_artifacts/coverage_report_worker.rb'
-    - 'app/workers/ci/pipeline_artifacts/create_quality_report_worker.rb'
-    - 'app/workers/ci/pipeline_artifacts/expire_artifacts_worker.rb'
-    - 'app/workers/ci/pipeline_success_unlock_artifacts_worker.rb'
-    - 'app/workers/ci/ref_delete_unlock_artifacts_worker.rb'
-    - 'app/workers/ci/resource_groups/assign_resource_from_resource_group_worker.rb'
-    - 'app/workers/ci/schedule_delete_objects_cron_worker.rb'
-    - 'app/workers/ci/test_failure_history_worker.rb'
-    - 'app/workers/ci_platform_metrics_update_cron_worker.rb'
-    - 'app/workers/cleanup_container_repository_worker.rb'
-    - 'app/workers/cluster_configure_istio_worker.rb'
-    - 'app/workers/cluster_install_app_worker.rb'
-    - 'app/workers/cluster_patch_app_worker.rb'
-    - 'app/workers/cluster_provision_worker.rb'
-    - 'app/workers/cluster_update_app_worker.rb'
-    - 'app/workers/cluster_upgrade_app_worker.rb'
-    - 'app/workers/cluster_wait_for_app_installation_worker.rb'
-    - 'app/workers/cluster_wait_for_app_update_worker.rb'
-    - 'app/workers/cluster_wait_for_ingress_ip_address_worker.rb'
-    - 'app/workers/clusters/applications/activate_service_worker.rb'
-    - 'app/workers/clusters/applications/check_prometheus_health_worker.rb'
-    - 'app/workers/clusters/applications/deactivate_service_worker.rb'
-    - 'app/workers/clusters/applications/uninstall_worker.rb'
-    - 'app/workers/clusters/applications/wait_for_uninstall_app_worker.rb'
-    - 'app/workers/container_expiration_policies/cleanup_container_repository_worker.rb'
-    - 'app/workers/container_expiration_policy_worker.rb'
-    - 'app/workers/create_commit_signature_worker.rb'
-    - 'app/workers/create_note_diff_file_worker.rb'
-    - 'app/workers/create_pipeline_worker.rb'
-    - 'app/workers/database/batched_background_migration_worker.rb'
-    - 'app/workers/database/partition_management_worker.rb'
-    - 'app/workers/delete_container_repository_worker.rb'
-    - 'app/workers/delete_diff_files_worker.rb'
-    - 'app/workers/delete_merged_branches_worker.rb'
-    - 'app/workers/delete_stored_files_worker.rb'
-    - 'app/workers/delete_user_worker.rb'
-    - 'app/workers/deployments/drop_older_deployments_worker.rb'
-    - 'app/workers/deployments/finished_worker.rb'
-    - 'app/workers/deployments/forward_deployment_worker.rb'
-    - 'app/workers/deployments/hooks_worker.rb'
-    - 'app/workers/deployments/link_merge_request_worker.rb'
-    - 'app/workers/deployments/success_worker.rb'
-    - 'app/workers/deployments/update_environment_worker.rb'
-    - 'app/workers/design_management/copy_design_collection_worker.rb'
-    - 'app/workers/design_management/new_version_worker.rb'
-    - 'app/workers/destroy_pages_deployments_worker.rb'
-    - 'app/workers/detect_repository_languages_worker.rb'
-    - 'app/workers/disallow_two_factor_for_group_worker.rb'
-    - 'app/workers/disallow_two_factor_for_subgroups_worker.rb'
-    - 'app/workers/email_receiver_worker.rb'
-    - 'app/workers/emails_on_push_worker.rb'
-    - 'app/workers/environments/auto_stop_cron_worker.rb'
-    - 'app/workers/environments/canary_ingress/update_worker.rb'
-    - 'app/workers/error_tracking_issue_link_worker.rb'
-    - 'app/workers/experiments/record_conversion_event_worker.rb'
-    - 'app/workers/expire_build_artifacts_worker.rb'
-    - 'app/workers/expire_build_instance_artifacts_worker.rb'
-    - 'app/workers/expire_job_cache_worker.rb'
-    - 'app/workers/export_csv_worker.rb'
-    - 'app/workers/file_hook_worker.rb'
-    - 'app/workers/flush_counter_increments_worker.rb'
-    - 'app/workers/gitlab/github_import/advance_stage_worker.rb'
-    - 'app/workers/gitlab/github_import/refresh_import_jid_worker.rb'
-    - 'app/workers/gitlab/github_import/stage/finish_import_worker.rb'
-    - 'app/workers/gitlab/github_import/stage/import_base_data_worker.rb'
-    - 'app/workers/gitlab/github_import/stage/import_issues_and_diff_notes_worker.rb'
-    - 'app/workers/gitlab/github_import/stage/import_lfs_objects_worker.rb'
-    - 'app/workers/gitlab/github_import/stage/import_notes_worker.rb'
-    - 'app/workers/gitlab/github_import/stage/import_pull_requests_merged_by_worker.rb'
-    - 'app/workers/gitlab/github_import/stage/import_pull_requests_reviews_worker.rb'
-    - 'app/workers/gitlab/github_import/stage/import_pull_requests_worker.rb'
-    - 'app/workers/gitlab/github_import/stage/import_repository_worker.rb'
-    - 'app/workers/gitlab/jira_import/advance_stage_worker.rb'
-    - 'app/workers/gitlab/jira_import/import_issue_worker.rb'
-    - 'app/workers/gitlab/jira_import/stage/start_import_worker.rb'
-    - 'app/workers/gitlab/phabricator_import/import_tasks_worker.rb'
-    - 'app/workers/gitlab_performance_bar_stats_worker.rb'
-    - 'app/workers/gitlab_service_ping_worker.rb'
-    - 'app/workers/gitlab_shell_worker.rb'
-    - 'app/workers/group_destroy_worker.rb'
-    - 'app/workers/group_export_worker.rb'
-    - 'app/workers/group_import_worker.rb'
-    - 'app/workers/hashed_storage/migrator_worker.rb'
-    - 'app/workers/hashed_storage/project_migrate_worker.rb'
-    - 'app/workers/hashed_storage/project_rollback_worker.rb'
-    - 'app/workers/hashed_storage/rollbacker_worker.rb'
-    - 'app/workers/import_export_project_cleanup_worker.rb'
-    - 'app/workers/import_issues_csv_worker.rb'
-    - 'app/workers/incident_management/add_severity_system_note_worker.rb'
-    - 'app/workers/incident_management/pager_duty/process_incident_worker.rb'
-    - 'app/workers/incident_management/process_alert_worker_v2.rb'
-    - 'app/workers/invalid_gpg_signature_update_worker.rb'
-    - 'app/workers/irker_worker.rb'
-    - 'app/workers/issuable/label_links_destroy_worker.rb'
-    - 'app/workers/issuable_export_csv_worker.rb'
-    - 'app/workers/issuables/clear_groups_issue_counter_worker.rb'
-    - 'app/workers/issue_due_scheduler_worker.rb'
-    - 'app/workers/issue_placement_worker.rb'
-    - 'app/workers/issue_rebalancing_worker.rb'
-    - 'app/workers/jira_connect/forward_event_worker.rb'
-    - 'app/workers/jira_connect/sync_branch_worker.rb'
-    - 'app/workers/jira_connect/sync_builds_worker.rb'
-    - 'app/workers/jira_connect/sync_deployments_worker.rb'
-    - 'app/workers/jira_connect/sync_feature_flags_worker.rb'
-    - 'app/workers/jira_connect/sync_merge_request_worker.rb'
-    - 'app/workers/jira_connect/sync_project_worker.rb'
-    - 'app/workers/mail_scheduler/issue_due_worker.rb'
-    - 'app/workers/mail_scheduler/notification_service_worker.rb'
-    - 'app/workers/member_invitation_reminder_emails_worker.rb'
-    - 'app/workers/members_destroyer/unassign_issuables_worker.rb'
-    - 'app/workers/merge_request_cleanup_refs_worker.rb'
-    - 'app/workers/merge_request_mergeability_check_worker.rb'
-    - 'app/workers/merge_requests/create_pipeline_worker.rb'
-    - 'app/workers/merge_requests/delete_source_branch_worker.rb'
-    - 'app/workers/merge_requests/handle_assignees_change_worker.rb'
-    - 'app/workers/merge_requests/resolve_todos_worker.rb'
-    - 'app/workers/merge_worker.rb'
-    - 'app/workers/metrics/dashboard/prune_old_annotations_worker.rb'
-    - 'app/workers/metrics/dashboard/schedule_annotations_prune_worker.rb'
-    - 'app/workers/metrics/dashboard/sync_dashboards_worker.rb'
-    - 'app/workers/migrate_external_diffs_worker.rb'
-    - 'app/workers/namespaceless_project_destroy_worker.rb'
-    - 'app/workers/namespaces/in_product_marketing_emails_worker.rb'
-    - 'app/workers/namespaces/onboarding_issue_created_worker.rb'
-    - 'app/workers/namespaces/onboarding_pipeline_created_worker.rb'
-    - 'app/workers/namespaces/onboarding_progress_worker.rb'
-    - 'app/workers/namespaces/onboarding_user_added_worker.rb'
-    - 'app/workers/namespaces/prune_aggregation_schedules_worker.rb'
-    - 'app/workers/namespaces/root_statistics_worker.rb'
-    - 'app/workers/namespaces/schedule_aggregation_worker.rb'
-    - 'app/workers/new_issue_worker.rb'
-    - 'app/workers/new_merge_request_worker.rb'
-    - 'app/workers/new_note_worker.rb'
-    - 'app/workers/object_pool/create_worker.rb'
-    - 'app/workers/object_pool/destroy_worker.rb'
-    - 'app/workers/object_pool/join_worker.rb'
-    - 'app/workers/object_pool/schedule_join_worker.rb'
-    - 'app/workers/object_storage/background_move_worker.rb'
-    - 'app/workers/object_storage/migrate_uploads_worker.rb'
-    - 'app/workers/packages/composer/cache_cleanup_worker.rb'
-    - 'app/workers/packages/composer/cache_update_worker.rb'
-    - 'app/workers/packages/debian/generate_distribution_worker.rb'
-    - 'app/workers/packages/debian/process_changes_worker.rb'
-    - 'app/workers/packages/go/sync_packages_worker.rb'
-    - 'app/workers/packages/helm/extraction_worker.rb'
-    - 'app/workers/packages/maven/metadata/sync_worker.rb'
-    - 'app/workers/packages/nuget/extraction_worker.rb'
-    - 'app/workers/packages/rubygems/extraction_worker.rb'
-    - 'app/workers/pages_domain_removal_cron_worker.rb'
-    - 'app/workers/pages_domain_ssl_renewal_cron_worker.rb'
-    - 'app/workers/pages_domain_ssl_renewal_worker.rb'
-    - 'app/workers/pages_domain_verification_cron_worker.rb'
-    - 'app/workers/pages_domain_verification_worker.rb'
-    - 'app/workers/pages_remove_worker.rb'
-    - 'app/workers/pages_transfer_worker.rb'
-    - 'app/workers/pages_update_configuration_worker.rb'
-    - 'app/workers/pages_worker.rb'
-    - 'app/workers/partition_creation_worker.rb'
-    - 'app/workers/personal_access_tokens/expired_notification_worker.rb'
-    - 'app/workers/personal_access_tokens/expiring_worker.rb'
-    - 'app/workers/pipeline_metrics_worker.rb'
-    - 'app/workers/pipeline_notification_worker.rb'
-    - 'app/workers/pipeline_process_worker.rb'
-    - 'app/workers/pipeline_schedule_worker.rb'
-    - 'app/workers/post_receive.rb'
-    - 'app/workers/process_commit_worker.rb'
-    - 'app/workers/project_cache_worker.rb'
-    - 'app/workers/project_daily_statistics_worker.rb'
-    - 'app/workers/project_destroy_worker.rb'
-    - 'app/workers/project_export_worker.rb'
-    - 'app/workers/project_service_worker.rb'
-    - 'app/workers/projects/post_creation_worker.rb'
-    - 'app/workers/projects/schedule_bulk_repository_shard_moves_worker.rb'
-    - 'app/workers/prometheus/create_default_alerts_worker.rb'
-    - 'app/workers/propagate_integration_group_worker.rb'
-    - 'app/workers/propagate_integration_inherit_descendant_worker.rb'
-    - 'app/workers/propagate_integration_inherit_worker.rb'
-    - 'app/workers/propagate_integration_project_worker.rb'
-    - 'app/workers/propagate_integration_worker.rb'
-    - 'app/workers/propagate_service_template_worker.rb'
-    - 'app/workers/prune_old_events_worker.rb'
-    - 'app/workers/purge_dependency_proxy_cache_worker.rb'
-    - 'app/workers/rebase_worker.rb'
-    - 'app/workers/releases/create_evidence_worker.rb'
-    - 'app/workers/releases/manage_evidence_worker.rb'
-    - 'app/workers/remote_mirror_notification_worker.rb'
-    - 'app/workers/remove_expired_group_links_worker.rb'
-    - 'app/workers/remove_expired_members_worker.rb'
-    - 'app/workers/remove_unaccepted_member_invites_worker.rb'
-    - 'app/workers/remove_unreferenced_lfs_objects_worker.rb'
-    - 'app/workers/repository_archive_cache_worker.rb'
-    - 'app/workers/repository_check/batch_worker.rb'
-    - 'app/workers/repository_check/clear_worker.rb'
-    - 'app/workers/repository_check/dispatch_worker.rb'
-    - 'app/workers/repository_check/single_repository_worker.rb'
-    - 'app/workers/repository_cleanup_worker.rb'
-    - 'app/workers/repository_fork_worker.rb'
-    - 'app/workers/repository_import_worker.rb'
-    - 'app/workers/repository_remove_remote_worker.rb'
-    - 'app/workers/repository_update_remote_mirror_worker.rb'
-    - 'app/workers/requests_profiles_worker.rb'
-    - 'app/workers/run_pipeline_schedule_worker.rb'
-    - 'app/workers/schedule_merge_request_cleanup_refs_worker.rb'
-    - 'app/workers/schedule_migrate_external_diffs_worker.rb'
-    - 'app/workers/self_monitoring_project_create_worker.rb'
-    - 'app/workers/self_monitoring_project_delete_worker.rb'
-    - 'app/workers/service_desk_email_receiver_worker.rb'
-    - 'app/workers/snippets/schedule_bulk_repository_shard_moves_worker.rb'
-    - 'app/workers/ssh_keys/expired_notification_worker.rb'
-    - 'app/workers/ssh_keys/expiring_soon_notification_worker.rb'
-    - 'app/workers/stage_update_worker.rb'
-    - 'app/workers/stuck_ci_jobs_worker.rb'
-    - 'app/workers/stuck_export_jobs_worker.rb'
-    - 'app/workers/stuck_merge_jobs_worker.rb'
-    - 'app/workers/system_hook_push_worker.rb'
-    - 'app/workers/todos_destroyer/confidential_issue_worker.rb'
-    - 'app/workers/todos_destroyer/destroyed_issuable_worker.rb'
-    - 'app/workers/todos_destroyer/entity_leave_worker.rb'
-    - 'app/workers/todos_destroyer/group_private_worker.rb'
-    - 'app/workers/todos_destroyer/private_features_worker.rb'
-    - 'app/workers/todos_destroyer/project_private_worker.rb'
-    - 'app/workers/trending_projects_worker.rb'
-    - 'app/workers/update_container_registry_info_worker.rb'
-    - 'app/workers/update_external_pull_requests_worker.rb'
-    - 'app/workers/update_head_pipeline_for_merge_request_worker.rb'
-    - 'app/workers/update_highest_role_worker.rb'
-    - 'app/workers/update_merge_requests_worker.rb'
-    - 'app/workers/update_project_statistics_worker.rb'
-    - 'app/workers/upload_checksum_worker.rb'
-    - 'app/workers/user_status_cleanup/batch_worker.rb'
-    - 'app/workers/users/create_statistics_worker.rb'
-    - 'app/workers/users/deactivate_dormant_users_worker.rb'
-    - 'app/workers/wait_for_cluster_creation_worker.rb'
-    - 'app/workers/web_hooks/destroy_worker.rb'
-    - 'app/workers/web_hooks/log_execution_worker.rb'
-    - 'app/workers/x509_certificate_revoke_worker.rb'
-    - 'app/workers/x509_issuer_crl_check_worker.rb'
-    - 'ee/app/workers/active_user_count_threshold_worker.rb'
-    - 'ee/app/workers/adjourned_group_deletion_worker.rb'
-    - 'ee/app/workers/adjourned_project_deletion_worker.rb'
-    - 'ee/app/workers/adjourned_projects_deletion_cron_worker.rb'
-    - 'ee/app/workers/admin_emails_worker.rb'
-    - 'ee/app/workers/analytics/code_review_metrics_worker.rb'
-    - 'ee/app/workers/analytics/devops_adoption/create_all_snapshots_worker.rb'
-    - 'ee/app/workers/analytics/devops_adoption/create_snapshot_worker.rb'
-    - 'ee/app/workers/approval_rules/external_approval_rule_payload_worker.rb'
-    - 'ee/app/workers/ci/batch_reset_minutes_worker.rb'
-    - 'ee/app/workers/ci/sync_reports_to_report_approval_rules_worker.rb'
-    - 'ee/app/workers/clear_shared_runners_minutes_worker.rb'
-    - 'ee/app/workers/create_github_webhook_worker.rb'
-    - 'ee/app/workers/dast_site_validation_worker.rb'
-    - 'ee/app/workers/deployments/auto_rollback_worker.rb'
-    - 'ee/app/workers/dora/daily_metrics/refresh_worker.rb'
-    - 'ee/app/workers/dora/daily_metrics/refresh_worker.rb'
-    - 'ee/app/workers/elastic/migration_worker.rb'
-    - 'ee/app/workers/elastic_association_indexer_worker.rb'
-    - 'ee/app/workers/elastic_cluster_reindexing_cron_worker.rb'
-    - 'ee/app/workers/elastic_commit_indexer_worker.rb'
-    - 'ee/app/workers/elastic_delete_project_worker.rb'
-    - 'ee/app/workers/elastic_full_index_worker.rb'
-    - 'ee/app/workers/elastic_indexing_control_worker.rb'
-    - 'ee/app/workers/elastic_namespace_indexer_worker.rb'
-    - 'ee/app/workers/elastic_namespace_rollout_worker.rb'
-    - 'ee/app/workers/elastic_remove_expired_namespace_subscriptions_from_index_cron_worker.rb'
-    - 'ee/app/workers/epics/new_epic_issue_worker.rb'
-    - 'ee/app/workers/epics/update_epics_dates_worker.rb'
-    - 'ee/app/workers/geo/batch/project_registry_scheduler_worker.rb'
-    - 'ee/app/workers/geo/batch/project_registry_worker.rb'
-    - 'ee/app/workers/geo/container_repository_sync_worker.rb'
-    - 'ee/app/workers/geo/design_repository_sync_worker.rb'
-    - 'ee/app/workers/geo/destroy_worker.rb'
-    - 'ee/app/workers/geo/event_worker.rb'
-    - 'ee/app/workers/geo/file_download_worker.rb'
-    - 'ee/app/workers/geo/file_registry_removal_worker.rb'
-    - 'ee/app/workers/geo/file_removal_worker.rb'
-    - 'ee/app/workers/geo/hashed_storage_attachments_migration_worker.rb'
-    - 'ee/app/workers/geo/hashed_storage_migration_worker.rb'
-    - 'ee/app/workers/geo/metrics_update_worker.rb'
-    - 'ee/app/workers/geo/project_sync_worker.rb'
-    - 'ee/app/workers/geo/prune_event_log_worker.rb'
-    - 'ee/app/workers/geo/rename_repository_worker.rb'
-    - 'ee/app/workers/geo/repositories_clean_up_worker.rb'
-    - 'ee/app/workers/geo/repository_cleanup_worker.rb'
-    - 'ee/app/workers/geo/repository_verification/primary/single_worker.rb'
-    - 'ee/app/workers/geo/repository_verification/secondary/single_worker.rb'
-    - 'ee/app/workers/geo/reverification_batch_worker.rb'
-    - 'ee/app/workers/geo/scheduler/per_shard_scheduler_worker.rb'
-    - 'ee/app/workers/geo/scheduler/scheduler_worker.rb'
-    - 'ee/app/workers/geo/secondary/registry_consistency_worker.rb'
-    - 'ee/app/workers/geo/secondary_usage_data_cron_worker.rb'
-    - 'ee/app/workers/geo/sidekiq_cron_config_worker.rb'
-    - 'ee/app/workers/geo/sync_timeout_cron_worker.rb'
-    - 'ee/app/workers/geo/verification_batch_worker.rb'
-    - 'ee/app/workers/geo/verification_cron_worker.rb'
-    - 'ee/app/workers/geo/verification_timeout_worker.rb'
-    - 'ee/app/workers/geo/verification_worker.rb'
-    - 'ee/app/workers/geo_repository_destroy_worker.rb'
-    - 'ee/app/workers/group_saml_group_sync_worker.rb'
-    - 'ee/app/workers/groups/schedule_bulk_repository_shard_moves_worker.rb'
-    - 'ee/app/workers/groups/update_statistics_worker.rb'
-    - 'ee/app/workers/historical_data_worker.rb'
-    - 'ee/app/workers/import_software_licenses_worker.rb'
-    - 'ee/app/workers/incident_management/apply_incident_sla_exceeded_label_worker.rb'
-    - 'ee/app/workers/incident_management/incident_sla_exceeded_check_worker.rb'
-    - 'ee/app/workers/incident_management/oncall_rotations/persist_all_rotations_shifts_job.rb'
-    - 'ee/app/workers/incident_management/oncall_rotations/persist_shifts_job.rb'
-    - 'ee/app/workers/incident_management/pending_escalations/alert_check_worker.rb'
-    - 'ee/app/workers/incident_management/pending_escalations/alert_create_worker.rb'
-    - 'ee/app/workers/incident_management/pending_escalations/schedule_check_cron_worker.rb'
-    - 'ee/app/workers/iterations/cadences/create_iterations_worker.rb'
-    - 'ee/app/workers/iterations/cadences/schedule_create_iterations_worker.rb'
-    - 'ee/app/workers/iterations/roll_over_issues_worker.rb'
-    - 'ee/app/workers/iterations_update_status_worker.rb'
-    - 'ee/app/workers/ldap_all_groups_sync_worker.rb'
-    - 'ee/app/workers/ldap_group_sync_worker.rb'
-    - 'ee/app/workers/ldap_sync_worker.rb'
-    - 'ee/app/workers/merge_request_reset_approvals_worker.rb'
-    - 'ee/app/workers/merge_requests/sync_code_owner_approval_rules_worker.rb'
-    - 'ee/app/workers/merge_trains/refresh_worker.rb'
-    - 'ee/app/workers/network_policy_metrics_worker.rb'
-    - 'ee/app/workers/new_epic_worker.rb'
-    - 'ee/app/workers/personal_access_tokens/groups/policy_worker.rb'
-    - 'ee/app/workers/personal_access_tokens/instance/policy_worker.rb'
-    - 'ee/app/workers/project_import_schedule_worker.rb'
-    - 'ee/app/workers/pseudonymizer_worker.rb'
-    - 'ee/app/workers/refresh_license_compliance_checks_worker.rb'
-    - 'ee/app/workers/repository_push_audit_event_worker.rb'
-    - 'ee/app/workers/repository_update_mirror_worker.rb'
-    - 'ee/app/workers/requirements_management/import_requirements_csv_worker.rb'
-    - 'ee/app/workers/requirements_management/process_requirements_reports_worker.rb'
-    - 'ee/app/workers/scan_security_report_secrets_worker.rb'
-    - 'ee/app/workers/security/auto_fix_worker.rb'
-    - 'ee/app/workers/security/create_orchestration_policy_worker.rb'
-    - 'ee/app/workers/security/orchestration_policy_rule_schedule_worker.rb'
-    - 'ee/app/workers/security/store_scans_worker.rb'
-    - 'ee/app/workers/security/track_secure_scans_worker.rb'
-    - 'ee/app/workers/set_user_status_based_on_user_cap_setting_worker.rb'
-    - 'ee/app/workers/status_page/publish_worker.rb'
-    - 'ee/app/workers/store_security_reports_worker.rb'
-    - 'ee/app/workers/store_security_scans_worker.rb'
-    - 'ee/app/workers/sync_seat_link_request_worker.rb'
-    - 'ee/app/workers/sync_seat_link_worker.rb'
-    - 'ee/app/workers/todos_destroyer/confidential_epic_worker.rb'
-    - 'ee/app/workers/update_all_mirrors_worker.rb'
-    - 'ee/app/workers/update_max_seats_used_for_gitlab_com_subscriptions_worker.rb'
-    - 'ee/app/workers/vulnerabilities/historical_statistics/deletion_worker.rb'
-    - 'ee/app/workers/vulnerabilities/statistics/adjustment_worker.rb'
-    - 'ee/app/workers/vulnerabilities/statistics/schedule_worker.rb'
-    - 'ee/app/workers/vulnerability_exports/export_deletion_worker.rb'
-    - 'ee/app/workers/vulnerability_exports/export_worker.rb'

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

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
 

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

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!

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

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

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

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

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

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!

app/workers/authorized_projects_worker.rb

@@ -3,6 +3,8 @@
 class AuthorizedProjectsWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   prepend WaitableWorker
 

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
 

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

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

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
 

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
 

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
 

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

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

app/workers/bulk_imports/relation_export_worker.rb

@@ -3,6 +3,8 @@
 module BulkImports
   class RelationExportWorker
     include ApplicationWorker
+
+    data_consistency :always
     include ExceptionBacktrace
 
     idempotent!

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
 

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
 

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

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
 

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
 

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

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
 

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
 

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
 

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
 

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
 

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
 

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
 

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
 

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

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
 

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
 

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
 

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
 

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

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

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
 

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
 

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
 

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

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
 

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

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

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
 

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

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

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
 

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

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

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

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

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

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
 

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

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
 

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

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

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

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

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

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

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
 

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
 

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!
 

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
 

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

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

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!

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

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

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

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

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
 

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

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

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

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

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

app/workers/destroy_pages_deployments_worker.rb

@@ -3,6 +3,8 @@
 class DestroyPagesDeploymentsWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   idempotent!
 
   loggable_arguments 0, 1

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
 

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
 

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
 

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

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

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
 

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!

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

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

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

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

app/workers/expire_job_cache_worker.rb

@@ -3,6 +3,8 @@
 class ExpireJobCacheWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   include PipelineQueue
 

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

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

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!

app/workers/gitlab/github_import/advance_stage_worker.rb

@@ -9,6 +9,8 @@ module Gitlab
     class AdvanceStageWorker # rubocop:disable Scalability/IdempotentWorker
       include ApplicationWorker
 
+      data_consistency :always
+
       sidekiq_options retry: 3
       include ::Gitlab::Import::AdvanceStage
 

app/workers/gitlab/github_import/refresh_import_jid_worker.rb

@@ -5,6 +5,8 @@ module Gitlab
     class RefreshImportJidWorker # rubocop:disable Scalability/IdempotentWorker
       include ApplicationWorker
 
+      data_consistency :always
+
       sidekiq_options retry: 3
       include GithubImport::Queue
 

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

@@ -6,6 +6,8 @@ module Gitlab
       class FinishImportWorker # rubocop:disable Scalability/IdempotentWorker
         include ApplicationWorker
 
+        data_consistency :always
+
         sidekiq_options retry: 3
         include GithubImport::Queue
         include StageMethods

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

@@ -6,6 +6,8 @@ module Gitlab
       class ImportBaseDataWorker # rubocop:disable Scalability/IdempotentWorker
         include ApplicationWorker
 
+        data_consistency :always
+
         sidekiq_options retry: 3
         include GithubImport::Queue
         include StageMethods

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

@@ -6,6 +6,8 @@ module Gitlab
       class ImportIssuesAndDiffNotesWorker # rubocop:disable Scalability/IdempotentWorker
         include ApplicationWorker
 
+        data_consistency :always
+
         sidekiq_options retry: 3
         include GithubImport::Queue
         include StageMethods

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

@@ -6,6 +6,8 @@ module Gitlab
       class ImportLfsObjectsWorker # rubocop:disable Scalability/IdempotentWorker
         include ApplicationWorker
 
+        data_consistency :always
+
         sidekiq_options retry: 3
         include GithubImport::Queue
         include StageMethods

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

@@ -6,6 +6,8 @@ module Gitlab
       class ImportNotesWorker # rubocop:disable Scalability/IdempotentWorker
         include ApplicationWorker
 
+        data_consistency :always
+
         sidekiq_options retry: 3
         include GithubImport::Queue
         include StageMethods

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

@@ -6,6 +6,8 @@ module Gitlab
       class ImportPullRequestsMergedByWorker # rubocop:disable Scalability/IdempotentWorker
         include ApplicationWorker
 
+        data_consistency :always
+
         sidekiq_options retry: 3
         include GithubImport::Queue
         include StageMethods

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

@@ -6,6 +6,8 @@ module Gitlab
       class ImportPullRequestsReviewsWorker # rubocop:disable Scalability/IdempotentWorker
         include ApplicationWorker
 
+        data_consistency :always
+
         sidekiq_options retry: 3
         include GithubImport::Queue
         include StageMethods

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

@@ -6,6 +6,8 @@ module Gitlab
       class ImportPullRequestsWorker # rubocop:disable Scalability/IdempotentWorker
         include ApplicationWorker
 
+        data_consistency :always
+
         sidekiq_options retry: 3
         include GithubImport::Queue
         include StageMethods

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

@@ -6,6 +6,8 @@ module Gitlab
       class ImportRepositoryWorker # rubocop:disable Scalability/IdempotentWorker
         include ApplicationWorker
 
+        data_consistency :always
+
         sidekiq_options retry: 3
         include GithubImport::Queue
         include StageMethods

app/workers/gitlab/jira_import/advance_stage_worker.rb

@@ -5,6 +5,8 @@ module Gitlab
     class AdvanceStageWorker # rubocop:disable Scalability/IdempotentWorker
       include ApplicationWorker
 
+      data_consistency :always
+
       sidekiq_options retry: 3
       include QueueOptions
       include ::Gitlab::Import::AdvanceStage

app/workers/gitlab/jira_import/import_issue_worker.rb

@@ -5,6 +5,8 @@ module Gitlab
     class ImportIssueWorker # rubocop:disable Scalability/IdempotentWorker
       include ApplicationWorker
 
+      data_consistency :always
+
       sidekiq_options retry: 3
       include NotifyUponDeath
       include Gitlab::JiraImport::QueueOptions

app/workers/gitlab/jira_import/stage/start_import_worker.rb

@@ -6,6 +6,8 @@ module Gitlab
       class StartImportWorker # rubocop:disable Scalability/IdempotentWorker
         include ApplicationWorker
 
+        data_consistency :always
+
         sidekiq_options retry: 3
         include ProjectStartImport
         include ProjectImportOptions

app/workers/gitlab/phabricator_import/import_tasks_worker.rb

@@ -4,6 +4,8 @@ module Gitlab
     class ImportTasksWorker < BaseWorker # rubocop:disable Scalability/IdempotentWorker
       include ApplicationWorker
 
+      data_consistency :always
+
       sidekiq_options retry: 3
       include ProjectImportOptions # This marks the project as failed after too many tries
 

app/workers/gitlab_performance_bar_stats_worker.rb

@@ -3,6 +3,8 @@
 class GitlabPerformanceBarStatsWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
 
   LEASE_KEY = 'gitlab:performance_bar_stats'

app/workers/gitlab_service_ping_worker.rb

@@ -5,6 +5,8 @@ class GitlabServicePingWorker # rubocop:disable Scalability/IdempotentWorker
   LEASE_TIMEOUT = 86400
 
   include ApplicationWorker
+
+  data_consistency :always
   include CronjobQueue # rubocop:disable Scalability/CronWorkerContext
   include Gitlab::ExclusiveLeaseHelpers
 

app/workers/gitlab_shell_worker.rb

@@ -3,6 +3,8 @@
 class GitlabShellWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   include Gitlab::ShellAdapter
 

app/workers/group_destroy_worker.rb

@@ -3,6 +3,8 @@
 class GroupDestroyWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   include ExceptionBacktrace
 

app/workers/group_export_worker.rb

@@ -2,6 +2,8 @@
 
 class GroupExportWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
+
+  data_consistency :always
   include ExceptionBacktrace
 
   feature_category :importers

app/workers/group_import_worker.rb

@@ -3,6 +3,8 @@
 class GroupImportWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: false, dead: false
   feature_category :importers
 

app/workers/hashed_storage/migrator_worker.rb

@@ -4,6 +4,8 @@ module HashedStorage
   class MigratorWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
 
     queue_namespace :hashed_storage

app/workers/hashed_storage/project_migrate_worker.rb

@@ -4,6 +4,8 @@ module HashedStorage
   class ProjectMigrateWorker < BaseWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
 
     queue_namespace :hashed_storage

app/workers/hashed_storage/project_rollback_worker.rb

@@ -4,6 +4,8 @@ module HashedStorage
   class ProjectRollbackWorker < BaseWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
 
     queue_namespace :hashed_storage

app/workers/hashed_storage/rollbacker_worker.rb

@@ -4,6 +4,8 @@ module HashedStorage
   class RollbackerWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
 
     queue_namespace :hashed_storage

app/workers/import_export_project_cleanup_worker.rb

@@ -3,6 +3,8 @@
 class ImportExportProjectCleanupWorker # 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

app/workers/import_issues_csv_worker.rb

@@ -3,6 +3,8 @@
 class ImportIssuesCsvWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
 
   idempotent!

app/workers/incident_management/add_severity_system_note_worker.rb

@@ -4,6 +4,8 @@ module IncidentManagement
   class AddSeveritySystemNoteWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
 
     queue_namespace :incident_management

app/workers/incident_management/pager_duty/process_incident_worker.rb

@@ -5,6 +5,8 @@ module IncidentManagement
     class ProcessIncidentWorker # rubocop:disable Scalability/IdempotentWorker
       include ApplicationWorker
 
+      data_consistency :always
+
       sidekiq_options retry: 3
 
       queue_namespace :incident_management

app/workers/incident_management/process_alert_worker_v2.rb

@@ -4,6 +4,8 @@ module IncidentManagement
   class ProcessAlertWorkerV2 # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     queue_namespace :incident_management
     feature_category :incident_management
 

app/workers/invalid_gpg_signature_update_worker.rb

@@ -3,6 +3,8 @@
 class InvalidGpgSignatureUpdateWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
 
   feature_category :source_code_management

app/workers/irker_worker.rb

@@ -6,6 +6,8 @@ require 'socket'
 class IrkerWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
 
   feature_category :integrations

app/workers/issuable/label_links_destroy_worker.rb

@@ -4,6 +4,8 @@ module Issuable
   class LabelLinksDestroyWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     idempotent!
     feature_category :issue_tracking
 

app/workers/issuable_export_csv_worker.rb

@@ -3,6 +3,8 @@
 class IssuableExportCsvWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
 
   feature_category :issue_tracking

app/workers/issuables/clear_groups_issue_counter_worker.rb

@@ -4,6 +4,8 @@ module Issuables
   class ClearGroupsIssueCounterWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     idempotent!
     urgency :low
     feature_category :issue_tracking

app/workers/issue_due_scheduler_worker.rb

@@ -3,6 +3,8 @@
 class IssueDueSchedulerWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   include CronjobQueue # rubocop:disable Scalability/CronWorkerContext
 

app/workers/issue_placement_worker.rb

@@ -3,6 +3,8 @@
 class IssuePlacementWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
 
   idempotent!

app/workers/issue_rebalancing_worker.rb

@@ -3,6 +3,8 @@
 class IssueRebalancingWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
 
   idempotent!

app/workers/jira_connect/forward_event_worker.rb

@@ -4,6 +4,8 @@ module JiraConnect
   class ForwardEventWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     queue_namespace :jira_connect
     feature_category :integrations
     worker_has_external_dependencies!

app/workers/mail_scheduler/issue_due_worker.rb

@@ -4,6 +4,8 @@ module MailScheduler
   class IssueDueWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
     include MailSchedulerQueue
 

app/workers/mail_scheduler/notification_service_worker.rb

@@ -6,6 +6,8 @@ module MailScheduler
   class NotificationServiceWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
     include MailSchedulerQueue
 

app/workers/member_invitation_reminder_emails_worker.rb

@@ -3,6 +3,8 @@
 class MemberInvitationReminderEmailsWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   include CronjobQueue # rubocop:disable Scalability/CronWorkerContext
 

app/workers/members_destroyer/unassign_issuables_worker.rb

@@ -4,6 +4,8 @@ module MembersDestroyer
   class UnassignIssuablesWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
 
     ENTITY_TYPES = %w(Group Project).freeze

app/workers/merge_request_cleanup_refs_worker.rb

@@ -5,6 +5,8 @@ class MergeRequestCleanupRefsWorker
   include LimitedCapacity::Worker
   include Gitlab::Utils::StrongMemoize
 
+  data_consistency :always
+
   sidekiq_options retry: 3
 
   feature_category :code_review

app/workers/merge_request_mergeability_check_worker.rb

@@ -3,6 +3,8 @@
 class MergeRequestMergeabilityCheckWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
 
   feature_category :code_review

app/workers/merge_requests/create_pipeline_worker.rb

@@ -4,6 +4,8 @@ module MergeRequests
   class CreatePipelineWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
     include PipelineQueue
 

app/workers/merge_requests/delete_source_branch_worker.rb

@@ -3,6 +3,8 @@
 class MergeRequests::DeleteSourceBranchWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
 
   feature_category :source_code_management

app/workers/merge_requests/handle_assignees_change_worker.rb

@@ -3,6 +3,8 @@
 class MergeRequests::HandleAssigneesChangeWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
 
   feature_category :code_review

app/workers/merge_requests/resolve_todos_worker.rb

@@ -3,6 +3,8 @@
 class MergeRequests::ResolveTodosWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
 
   feature_category :code_review

app/workers/merge_worker.rb

@@ -3,6 +3,8 @@
 class MergeWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
 
   feature_category :source_code_management

app/workers/metrics/dashboard/prune_old_annotations_worker.rb

@@ -5,6 +5,8 @@ module Metrics
     class PruneOldAnnotationsWorker
       include ApplicationWorker
 
+      data_consistency :always
+
       sidekiq_options retry: 3
 
       DELETE_LIMIT = 10_000

app/workers/metrics/dashboard/schedule_annotations_prune_worker.rb

@@ -5,6 +5,8 @@ module Metrics
     class ScheduleAnnotationsPruneWorker
       include ApplicationWorker
 
+      data_consistency :always
+
       sidekiq_options retry: 3
       # rubocop:disable Scalability/CronWorkerContext
       # This worker does not perform work scoped to a context

app/workers/metrics/dashboard/sync_dashboards_worker.rb

@@ -5,6 +5,8 @@ module Metrics
     class SyncDashboardsWorker
       include ApplicationWorker
 
+      data_consistency :always
+
       sidekiq_options retry: 3
 
       feature_category :metrics

app/workers/migrate_external_diffs_worker.rb

@@ -3,6 +3,8 @@
 class MigrateExternalDiffsWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
 
   feature_category :code_review

app/workers/namespaceless_project_destroy_worker.rb

@@ -9,6 +9,8 @@
 class NamespacelessProjectDestroyWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   include ExceptionBacktrace
 

app/workers/namespaces/in_product_marketing_emails_worker.rb

@@ -4,6 +4,8 @@ module Namespaces
   class InProductMarketingEmailsWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
     include CronjobQueue # rubocop:disable Scalability/CronWorkerContext
 

app/workers/namespaces/onboarding_issue_created_worker.rb

@@ -4,6 +4,8 @@ module Namespaces
   class OnboardingIssueCreatedWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
 
     feature_category :issue_tracking

app/workers/namespaces/onboarding_pipeline_created_worker.rb

@@ -4,6 +4,8 @@ module Namespaces
   class OnboardingPipelineCreatedWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
 
     feature_category :subgroups

app/workers/namespaces/onboarding_progress_worker.rb

@@ -4,6 +4,8 @@ module Namespaces
   class OnboardingProgressWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
 
     feature_category :product_analytics

app/workers/namespaces/onboarding_user_added_worker.rb

@@ -4,6 +4,8 @@ module Namespaces
   class OnboardingUserAddedWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
 
     feature_category :users

app/workers/namespaces/prune_aggregation_schedules_worker.rb

@@ -4,6 +4,8 @@ module Namespaces
   class PruneAggregationSchedulesWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
     include CronjobQueue # rubocop:disable Scalability/CronWorkerContext
 

app/workers/namespaces/root_statistics_worker.rb

@@ -4,6 +4,8 @@ module Namespaces
   class RootStatisticsWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
 
     queue_namespace :update_namespace_statistics

app/workers/namespaces/schedule_aggregation_worker.rb

@@ -4,6 +4,8 @@ module Namespaces
   class ScheduleAggregationWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
 
     queue_namespace :update_namespace_statistics

app/workers/new_issue_worker.rb

@@ -3,6 +3,8 @@
 class NewIssueWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   include NewIssuable
 

app/workers/new_merge_request_worker.rb

@@ -3,6 +3,8 @@
 class NewMergeRequestWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   include NewIssuable
 

app/workers/new_note_worker.rb

@@ -3,6 +3,8 @@
 class NewNoteWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
 
   feature_category :issue_tracking

app/workers/object_pool/create_worker.rb

@@ -4,6 +4,8 @@ module ObjectPool
   class CreateWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
     include ObjectPoolQueue
     include ExclusiveLeaseGuard

app/workers/object_pool/destroy_worker.rb

@@ -4,6 +4,8 @@ module ObjectPool
   class DestroyWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
     include ObjectPoolQueue
 

app/workers/object_pool/join_worker.rb

@@ -4,6 +4,8 @@ module ObjectPool
   class JoinWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
     include ObjectPoolQueue
 

app/workers/object_pool/schedule_join_worker.rb

@@ -4,6 +4,8 @@ module ObjectPool
   class ScheduleJoinWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
     include ObjectPoolQueue
 

app/workers/object_storage/background_move_worker.rb

@@ -3,6 +3,8 @@
 module ObjectStorage
   class BackgroundMoveWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
+
+    data_consistency :always
     include ObjectStorageQueue
 
     sidekiq_options retry: 5

app/workers/object_storage/migrate_uploads_worker.rb

@@ -5,6 +5,8 @@ module ObjectStorage
   class MigrateUploadsWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
     include ObjectStorageQueue
 

app/workers/packages/composer/cache_cleanup_worker.rb

@@ -5,6 +5,8 @@ module Packages
     class CacheCleanupWorker
       include ApplicationWorker
 
+      data_consistency :always
+
       sidekiq_options retry: 3
       include CronjobQueue # rubocop:disable Scalability/CronWorkerContext
 

app/workers/packages/composer/cache_update_worker.rb

@@ -5,6 +5,8 @@ module Packages
     class CacheUpdateWorker
       include ApplicationWorker
 
+      data_consistency :always
+
       sidekiq_options retry: 3
 
       feature_category :package_registry

app/workers/packages/debian/generate_distribution_worker.rb

@@ -4,6 +4,8 @@ module Packages
   module Debian
     class GenerateDistributionWorker # rubocop:disable Scalability/IdempotentWorker
       include ApplicationWorker
+
+      data_consistency :always
       include Gitlab::Utils::StrongMemoize
 
       # The worker is idempotent, by reusing component files with the same file_sha256.

app/workers/packages/debian/process_changes_worker.rb

@@ -4,6 +4,8 @@ module Packages
   module Debian
     class ProcessChangesWorker
       include ApplicationWorker
+
+      data_consistency :always
       include Gitlab::Utils::StrongMemoize
 
       deduplicate :until_executed

app/workers/packages/go/sync_packages_worker.rb

@@ -5,6 +5,8 @@ module Packages
     class SyncPackagesWorker
       include ApplicationWorker
 
+      data_consistency :always
+
       sidekiq_options retry: 3
       include Gitlab::Golang
 

app/workers/packages/helm/extraction_worker.rb

@@ -5,6 +5,8 @@ module Packages
     class ExtractionWorker
       include ApplicationWorker
 
+      data_consistency :always
+
       queue_namespace :package_repositories
       feature_category :package_registry
       deduplicate :until_executing

app/workers/packages/maven/metadata/sync_worker.rb

@@ -6,6 +6,8 @@ module Packages
       class SyncWorker
         include ApplicationWorker
 
+        data_consistency :always
+
         sidekiq_options retry: 3
         include Gitlab::Utils::StrongMemoize
 

app/workers/packages/nuget/extraction_worker.rb

@@ -5,6 +5,8 @@ module Packages
     class ExtractionWorker # rubocop:disable Scalability/IdempotentWorker
       include ApplicationWorker
 
+      data_consistency :always
+
       sidekiq_options retry: 3
 
       queue_namespace :package_repositories

app/workers/packages/rubygems/extraction_worker.rb

@@ -5,6 +5,8 @@ module Packages
     class ExtractionWorker # rubocop:disable Scalability/IdempotentWorker
       include ApplicationWorker
 
+      data_consistency :always
+
       sidekiq_options retry: 3
 
       queue_namespace :package_repositories

app/workers/pages_domain_removal_cron_worker.rb

@@ -3,6 +3,8 @@
 class PagesDomainRemovalCronWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   include CronjobQueue
 

app/workers/pages_domain_ssl_renewal_cron_worker.rb

@@ -3,6 +3,8 @@
 class PagesDomainSslRenewalCronWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   include CronjobQueue
 

app/workers/pages_domain_ssl_renewal_worker.rb

@@ -3,6 +3,8 @@
 class PagesDomainSslRenewalWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
 
   feature_category :pages

app/workers/pages_domain_verification_cron_worker.rb

@@ -3,6 +3,8 @@
 class PagesDomainVerificationCronWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   include CronjobQueue
 

app/workers/pages_domain_verification_worker.rb

@@ -3,6 +3,8 @@
 class PagesDomainVerificationWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
 
   feature_category :pages

app/workers/pages_remove_worker.rb

@@ -4,6 +4,8 @@
 class PagesRemoveWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   feature_category :pages
   tags :exclude_from_kubernetes

app/workers/pages_transfer_worker.rb

@@ -3,6 +3,8 @@
 class PagesTransferWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
 
   TransferFailedError = Class.new(StandardError)

app/workers/pages_update_configuration_worker.rb

@@ -3,6 +3,8 @@
 class PagesUpdateConfigurationWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
 
   idempotent!

app/workers/pages_worker.rb

@@ -3,6 +3,8 @@
 class PagesWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   feature_category :pages
   loggable_arguments 0, 1

app/workers/partition_creation_worker.rb

@@ -3,6 +3,8 @@
 class PartitionCreationWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   include CronjobQueue # rubocop:disable Scalability/CronWorkerContext
 

app/workers/personal_access_tokens/expired_notification_worker.rb

@@ -4,6 +4,8 @@ module PersonalAccessTokens
   class ExpiredNotificationWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
     include CronjobQueue
 

app/workers/personal_access_tokens/expiring_worker.rb

@@ -4,6 +4,8 @@ module PersonalAccessTokens
   class ExpiringWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
     include CronjobQueue
 

app/workers/pipeline_metrics_worker.rb

@@ -3,6 +3,8 @@
 class PipelineMetricsWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   include PipelineQueue
 

app/workers/pipeline_notification_worker.rb

@@ -3,6 +3,8 @@
 class PipelineNotificationWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   include PipelineQueue
 

app/workers/pipeline_process_worker.rb

@@ -3,6 +3,8 @@
 class PipelineProcessWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   include PipelineQueue
 

app/workers/pipeline_schedule_worker.rb

@@ -3,6 +3,8 @@
 class PipelineScheduleWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   include CronjobQueue
 

app/workers/post_receive.rb

@@ -3,6 +3,8 @@
 class PostReceive # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   include Gitlab::Experiment::Dsl
 

app/workers/process_commit_worker.rb

@@ -10,6 +10,8 @@
 class ProcessCommitWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
 
   feature_category :source_code_management

app/workers/project_cache_worker.rb

@@ -4,6 +4,8 @@
 class ProjectCacheWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
 
   LEASE_TIMEOUT = 15.minutes.to_i

app/workers/project_daily_statistics_worker.rb

@@ -4,6 +4,8 @@
 class ProjectDailyStatisticsWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
 
   feature_category :source_code_management

app/workers/project_destroy_worker.rb

@@ -3,6 +3,8 @@
 class ProjectDestroyWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   include ExceptionBacktrace
 

app/workers/project_export_worker.rb

@@ -2,6 +2,8 @@
 
 class ProjectExportWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
+
+  data_consistency :always
   include ExceptionBacktrace
 
   feature_category :importers

app/workers/project_service_worker.rb

@@ -3,6 +3,8 @@
 class ProjectServiceWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
 
   sidekiq_options dead: false

app/workers/projects/post_creation_worker.rb

@@ -4,6 +4,8 @@ module Projects
   class PostCreationWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
 
     feature_category :source_code_management

app/workers/projects/schedule_bulk_repository_shard_moves_worker.rb

@@ -4,6 +4,8 @@ module Projects
   class ScheduleBulkRepositoryShardMovesWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
 
     idempotent!

app/workers/prometheus/create_default_alerts_worker.rb

@@ -4,6 +4,8 @@ module Prometheus
   class CreateDefaultAlertsWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
 
     feature_category :incident_management

app/workers/propagate_integration_group_worker.rb

@@ -3,6 +3,8 @@
 class PropagateIntegrationGroupWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
 
   feature_category :integrations

app/workers/propagate_integration_inherit_descendant_worker.rb

@@ -3,6 +3,8 @@
 class PropagateIntegrationInheritDescendantWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
 
   feature_category :integrations

app/workers/propagate_integration_inherit_worker.rb

@@ -3,6 +3,8 @@
 class PropagateIntegrationInheritWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
 
   feature_category :integrations

app/workers/propagate_integration_project_worker.rb

@@ -3,6 +3,8 @@
 class PropagateIntegrationProjectWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
 
   feature_category :integrations

app/workers/propagate_integration_worker.rb

@@ -3,6 +3,8 @@
 class PropagateIntegrationWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
 
   feature_category :integrations

app/workers/propagate_service_template_worker.rb

@@ -4,6 +4,8 @@
 class PropagateServiceTemplateWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
 
   feature_category :integrations

app/workers/prune_old_events_worker.rb

@@ -3,6 +3,8 @@
 class PruneOldEventsWorker # 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

app/workers/purge_dependency_proxy_cache_worker.rb

@@ -3,6 +3,8 @@
 class PurgeDependencyProxyCacheWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   include Gitlab::Allowable
   idempotent!

app/workers/rebase_worker.rb

@@ -5,6 +5,8 @@
 class RebaseWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
 
   feature_category :source_code_management

app/workers/releases/create_evidence_worker.rb

@@ -4,6 +4,8 @@ module Releases
   class CreateEvidenceWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
 
     feature_category :release_evidence

app/workers/releases/manage_evidence_worker.rb

@@ -4,6 +4,8 @@ module Releases
   class ManageEvidenceWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
     include CronjobQueue # rubocop:disable Scalability/CronWorkerContext
 

app/workers/remote_mirror_notification_worker.rb

@@ -3,6 +3,8 @@
 class RemoteMirrorNotificationWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
 
   feature_category :source_code_management

app/workers/remove_expired_group_links_worker.rb

@@ -3,6 +3,8 @@
 class RemoveExpiredGroupLinksWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   include CronjobQueue # rubocop:disable Scalability/CronWorkerContext
 

app/workers/remove_expired_members_worker.rb

@@ -3,6 +3,8 @@
 class RemoveExpiredMembersWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   include CronjobQueue
 

app/workers/remove_unaccepted_member_invites_worker.rb

@@ -3,6 +3,8 @@
 class RemoveUnacceptedMemberInvitesWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   include CronjobQueue # rubocop:disable Scalability/CronWorkerContext
 

app/workers/remove_unreferenced_lfs_objects_worker.rb

@@ -3,6 +3,8 @@
 class RemoveUnreferencedLfsObjectsWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   # rubocop:disable Scalability/CronWorkerContext
   # This worker does not perform work scoped to a context

app/workers/repository_archive_cache_worker.rb

@@ -3,6 +3,8 @@
 class RepositoryArchiveCacheWorker # 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

app/workers/repository_check/batch_worker.rb

@@ -4,6 +4,8 @@ module RepositoryCheck
   class BatchWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
     include RepositoryCheckQueue
     include ExclusiveLeaseGuard

app/workers/repository_check/clear_worker.rb

@@ -4,6 +4,8 @@ module RepositoryCheck
   class ClearWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
     include RepositoryCheckQueue
 

app/workers/repository_check/dispatch_worker.rb

@@ -4,6 +4,8 @@ module RepositoryCheck
   class DispatchWorker # 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

app/workers/repository_check/single_repository_worker.rb

@@ -4,6 +4,8 @@ module RepositoryCheck
   class SingleRepositoryWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
     include RepositoryCheckQueue
 

app/workers/repository_cleanup_worker.rb

@@ -3,6 +3,8 @@
 class RepositoryCleanupWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   feature_category :source_code_management
 

app/workers/repository_fork_worker.rb

@@ -3,6 +3,8 @@
 class RepositoryForkWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   include ProjectStartImport
   include ProjectImportOptions

app/workers/repository_import_worker.rb

@@ -2,6 +2,8 @@
 
 class RepositoryImportWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
+
+  data_consistency :always
   include ExceptionBacktrace
   include ProjectStartImport
 

app/workers/repository_remove_remote_worker.rb

@@ -3,6 +3,8 @@
 class RepositoryRemoveRemoteWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   include ExclusiveLeaseGuard
 

app/workers/repository_update_remote_mirror_worker.rb

@@ -4,6 +4,8 @@ class RepositoryUpdateRemoteMirrorWorker
   UpdateError = Class.new(StandardError)
 
   include ApplicationWorker
+
+  data_consistency :always
   include Gitlab::ExclusiveLeaseHelpers
 
   worker_has_external_dependencies!

app/workers/requests_profiles_worker.rb

@@ -3,6 +3,8 @@
 class RequestsProfilesWorker # 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

app/workers/run_pipeline_schedule_worker.rb

@@ -3,6 +3,8 @@
 class RunPipelineScheduleWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   include PipelineQueue
 

app/workers/schedule_merge_request_cleanup_refs_worker.rb

@@ -3,6 +3,8 @@
 class ScheduleMergeRequestCleanupRefsWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   include CronjobQueue # rubocop:disable Scalability/CronWorkerContext
 

app/workers/schedule_migrate_external_diffs_worker.rb

@@ -3,6 +3,8 @@
 class ScheduleMigrateExternalDiffsWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   # rubocop:disable Scalability/CronWorkerContext:
   # This schedules the `MigrateExternalDiffsWorker`

app/workers/self_monitoring_project_create_worker.rb

@@ -3,6 +3,8 @@
 class SelfMonitoringProjectCreateWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   include ExclusiveLeaseGuard
   include SelfMonitoringProjectWorker

app/workers/self_monitoring_project_delete_worker.rb

@@ -3,6 +3,8 @@
 class SelfMonitoringProjectDeleteWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   include ExclusiveLeaseGuard
   include SelfMonitoringProjectWorker

app/workers/service_desk_email_receiver_worker.rb

@@ -3,6 +3,8 @@
 class ServiceDeskEmailReceiverWorker < EmailReceiverWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   feature_category :service_desk
   sidekiq_options retry: 3
 

app/workers/snippets/schedule_bulk_repository_shard_moves_worker.rb

@@ -4,6 +4,8 @@ module Snippets
   class ScheduleBulkRepositoryShardMovesWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
 
     idempotent!

app/workers/ssh_keys/expired_notification_worker.rb

@@ -4,6 +4,8 @@ module SshKeys
   class ExpiredNotificationWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
     include CronjobQueue
 

app/workers/ssh_keys/expiring_soon_notification_worker.rb

@@ -4,6 +4,8 @@ module SshKeys
   class ExpiringSoonNotificationWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
     include CronjobQueue
 

app/workers/stage_update_worker.rb

@@ -3,6 +3,8 @@
 class StageUpdateWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   include PipelineQueue
 

app/workers/stuck_ci_jobs_worker.rb

@@ -3,6 +3,8 @@
 class StuckCiJobsWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   include CronjobQueue
 

app/workers/stuck_export_jobs_worker.rb

@@ -4,6 +4,8 @@
 class StuckExportJobsWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   # rubocop:disable Scalability/CronWorkerContext
   # This worker updates export states inline and does not schedule

app/workers/stuck_merge_jobs_worker.rb

@@ -3,6 +3,8 @@
 class StuckMergeJobsWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   include CronjobQueue # rubocop:disable Scalability/CronWorkerContext
 

app/workers/system_hook_push_worker.rb

@@ -3,6 +3,8 @@
 class SystemHookPushWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
 
   feature_category :source_code_management

app/workers/todos_destroyer/confidential_issue_worker.rb

@@ -4,6 +4,8 @@ module TodosDestroyer
   class ConfidentialIssueWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
     include TodosDestroyerQueue
 

app/workers/todos_destroyer/destroyed_issuable_worker.rb

@@ -4,6 +4,8 @@ module TodosDestroyer
   class DestroyedIssuableWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
     include TodosDestroyerQueue
 

app/workers/todos_destroyer/entity_leave_worker.rb

@@ -4,6 +4,8 @@ module TodosDestroyer
   class EntityLeaveWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
     include TodosDestroyerQueue
 

app/workers/todos_destroyer/group_private_worker.rb

@@ -4,6 +4,8 @@ module TodosDestroyer
   class GroupPrivateWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
     include TodosDestroyerQueue
 

app/workers/todos_destroyer/private_features_worker.rb

@@ -4,6 +4,8 @@ module TodosDestroyer
   class PrivateFeaturesWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
     include TodosDestroyerQueue
 

app/workers/todos_destroyer/project_private_worker.rb

@@ -4,6 +4,8 @@ module TodosDestroyer
   class ProjectPrivateWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
     include TodosDestroyerQueue
 

app/workers/trending_projects_worker.rb

@@ -3,6 +3,8 @@
 class TrendingProjectsWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   include CronjobQueue # rubocop:disable Scalability/CronWorkerContext
 

app/workers/update_container_registry_info_worker.rb

@@ -3,6 +3,8 @@
 class UpdateContainerRegistryInfoWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   include CronjobQueue # rubocop:disable Scalability/CronWorkerContext
 

app/workers/update_external_pull_requests_worker.rb

@@ -3,6 +3,8 @@
 class UpdateExternalPullRequestsWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
 
   feature_category :source_code_management

app/workers/update_head_pipeline_for_merge_request_worker.rb

@@ -3,6 +3,8 @@
 class UpdateHeadPipelineForMergeRequestWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   include PipelineQueue
 

app/workers/update_highest_role_worker.rb

@@ -3,6 +3,8 @@
 class UpdateHighestRoleWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
 
   feature_category :utilization

app/workers/update_merge_requests_worker.rb

@@ -3,6 +3,8 @@
 class UpdateMergeRequestsWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
 
   feature_category :code_review

app/workers/update_project_statistics_worker.rb

@@ -4,6 +4,8 @@
 class UpdateProjectStatisticsWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
 
   feature_category :source_code_management

app/workers/upload_checksum_worker.rb

@@ -3,6 +3,8 @@
 class UploadChecksumWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
 
   feature_category :geo_replication

app/workers/user_status_cleanup/batch_worker.rb

@@ -5,6 +5,8 @@ module UserStatusCleanup
   class BatchWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
     # rubocop:disable Scalability/CronWorkerContext
     include CronjobQueue

app/workers/users/create_statistics_worker.rb

@@ -4,6 +4,8 @@ module Users
   class CreateStatisticsWorker # 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

app/workers/users/deactivate_dormant_users_worker.rb

@@ -4,6 +4,8 @@ module Users
   class DeactivateDormantUsersWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     include CronjobQueue
 
     feature_category :utilization

app/workers/wait_for_cluster_creation_worker.rb

@@ -3,6 +3,8 @@
 class WaitForClusterCreationWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   include ClusterQueue
 

app/workers/web_hooks/destroy_worker.rb

@@ -4,6 +4,8 @@ module WebHooks
   class DestroyWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
 
     feature_category :integrations

app/workers/web_hooks/log_execution_worker.rb

@@ -4,6 +4,8 @@ module WebHooks
   class LogExecutionWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     idempotent!
     feature_category :integrations
     urgency :low

app/workers/x509_certificate_revoke_worker.rb

@@ -3,6 +3,8 @@
 class X509CertificateRevokeWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
 
   feature_category :source_code_management

app/workers/x509_issuer_crl_check_worker.rb

@@ -3,6 +3,8 @@
 class X509IssuerCrlCheckWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   include CronjobQueue
 

ee/app/workers/active_user_count_threshold_worker.rb

@@ -3,6 +3,8 @@
 class ActiveUserCountThresholdWorker # 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

ee/app/workers/adjourned_group_deletion_worker.rb

@@ -3,6 +3,8 @@
 class AdjournedGroupDeletionWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   include CronjobQueue
 

ee/app/workers/adjourned_project_deletion_worker.rb

@@ -3,6 +3,8 @@
 class AdjournedProjectDeletionWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   include ExceptionBacktrace
 

ee/app/workers/adjourned_projects_deletion_cron_worker.rb

@@ -3,6 +3,8 @@
 class AdjournedProjectsDeletionCronWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   include CronjobQueue
 

ee/app/workers/admin_emails_worker.rb

@@ -3,6 +3,8 @@
 class AdminEmailsWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
 
   feature_category :issue_tracking

ee/app/workers/analytics/code_review_metrics_worker.rb

@@ -4,6 +4,8 @@ module Analytics
   class CodeReviewMetricsWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
 
     feature_category :code_analytics

ee/app/workers/analytics/devops_adoption/create_all_snapshots_worker.rb

@@ -6,6 +6,8 @@ module Analytics
     class CreateAllSnapshotsWorker
       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

ee/app/workers/analytics/devops_adoption/create_snapshot_worker.rb

@@ -6,6 +6,8 @@ module Analytics
     class CreateSnapshotWorker
       include ApplicationWorker
 
+      data_consistency :always
+
       sidekiq_options retry: 3
 
       feature_category :devops_reports

ee/app/workers/approval_rules/external_approval_rule_payload_worker.rb

@@ -4,6 +4,8 @@ module ApprovalRules
   class ExternalApprovalRulePayloadWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
     idempotent!
 

ee/app/workers/ci/batch_reset_minutes_worker.rb

@@ -4,6 +4,8 @@ module Ci
   class BatchResetMinutesWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 10
     feature_category :continuous_integration
     idempotent!

ee/app/workers/ci/sync_reports_to_report_approval_rules_worker.rb

@@ -5,6 +5,8 @@ module Ci
   class SyncReportsToReportApprovalRulesWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
     include PipelineBackgroundQueue
 

ee/app/workers/clear_shared_runners_minutes_worker.rb

@@ -3,6 +3,8 @@
 class ClearSharedRunnersMinutesWorker # 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

ee/app/workers/create_github_webhook_worker.rb

@@ -3,6 +3,8 @@
 class CreateGithubWebhookWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   include GrapePathHelpers::NamedRouteMatcher
 

ee/app/workers/dast_site_validation_worker.rb

@@ -3,6 +3,8 @@
 class DastSiteValidationWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   idempotent!
 
   sidekiq_options retry: 3, dead: false

ee/app/workers/deployments/auto_rollback_worker.rb

@@ -4,6 +4,8 @@ module Deployments
   class AutoRollbackWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
 
     idempotent!

ee/app/workers/dora/daily_metrics/refresh_worker.rb

@@ -5,6 +5,8 @@ module Dora
     class RefreshWorker
       include ApplicationWorker
 
+      data_consistency :always
+
       sidekiq_options retry: 3
 
       deduplicate :until_executing

ee/app/workers/elastic/migration_worker.rb

@@ -4,6 +4,8 @@ module Elastic
   class MigrationWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
     include Gitlab::ExclusiveLeaseHelpers
     # There is no onward scheduling and this cron handles work from across the

ee/app/workers/elastic_association_indexer_worker.rb

@@ -3,6 +3,8 @@
 class ElasticAssociationIndexerWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
 
   feature_category :global_search

ee/app/workers/elastic_cluster_reindexing_cron_worker.rb

@@ -2,6 +2,8 @@
 
 class ElasticClusterReindexingCronWorker
   include ApplicationWorker
+
+  data_consistency :always
   include CronjobQueue # rubocop:disable Scalability/CronWorkerContext
   include Gitlab::ExclusiveLeaseHelpers
 

ee/app/workers/elastic_commit_indexer_worker.rb

@@ -2,6 +2,8 @@
 
 class ElasticCommitIndexerWorker
   include ApplicationWorker
+
+  data_consistency :always
   prepend Elastic::IndexingControl
   include Gitlab::ExclusiveLeaseHelpers
 

ee/app/workers/elastic_delete_project_worker.rb

@@ -2,6 +2,8 @@
 
 class ElasticDeleteProjectWorker
   include ApplicationWorker
+
+  data_consistency :always
   include Elasticsearch::Model::Client::ClassMethods
   prepend Elastic::IndexingControl
 

ee/app/workers/elastic_full_index_worker.rb

@@ -7,6 +7,8 @@
 class ElasticFullIndexWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 2
   feature_category :global_search
 

ee/app/workers/elastic_indexing_control_worker.rb

@@ -3,6 +3,8 @@
 class ElasticIndexingControlWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
 
   feature_category :global_search

ee/app/workers/elastic_namespace_indexer_worker.rb

@@ -3,6 +3,8 @@
 class ElasticNamespaceIndexerWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   feature_category :global_search
   sidekiq_options retry: 2
   loggable_arguments 1

ee/app/workers/elastic_namespace_rollout_worker.rb

@@ -3,6 +3,8 @@
 class ElasticNamespaceRolloutWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   feature_category :global_search
   sidekiq_options retry: 2
   loggable_arguments 0, 2

ee/app/workers/elastic_remove_expired_namespace_subscriptions_from_index_cron_worker.rb

@@ -3,6 +3,8 @@
 class ElasticRemoveExpiredNamespaceSubscriptionsFromIndexCronWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   include Gitlab::ExclusiveLeaseHelpers
   include CronjobQueue

ee/app/workers/epics/new_epic_issue_worker.rb

@@ -4,6 +4,8 @@ module Epics
   class NewEpicIssueWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     feature_category :epics
 
     def perform(params)

ee/app/workers/epics/update_epics_dates_worker.rb

@@ -4,6 +4,8 @@ module Epics
   class UpdateEpicsDatesWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
 
     queue_namespace :epics

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

@@ -9,6 +9,8 @@ module Geo
     class ProjectRegistrySchedulerWorker # rubocop:disable Scalability/IdempotentWorker
       include ApplicationWorker
 
+      data_consistency :always
+
       sidekiq_options retry: 3
       include GeoQueue
       include ExclusiveLeaseGuard

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

@@ -9,6 +9,8 @@ module Geo
     class ProjectRegistryWorker # rubocop:disable Scalability/IdempotentWorker
       include ApplicationWorker
 
+      data_consistency :always
+
       sidekiq_options retry: 3
       include GeoQueue
       include ::Gitlab::Geo::LogHelpers

ee/app/workers/geo/container_repository_sync_worker.rb

@@ -3,6 +3,8 @@
 module Geo
   class ContainerRepositorySyncWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
+
+    data_consistency :always
     include GeoQueue
     include Gitlab::Geo::LogHelpers
 

ee/app/workers/geo/design_repository_sync_worker.rb

@@ -3,6 +3,8 @@
 module Geo
   class DesignRepositorySyncWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
+
+    data_consistency :always
     include GeoQueue
     include Gitlab::Geo::LogHelpers
 

ee/app/workers/geo/destroy_worker.rb

@@ -4,6 +4,8 @@ module Geo
   class DestroyWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
     include GeoQueue
     include ::Gitlab::Geo::LogHelpers

ee/app/workers/geo/event_worker.rb

@@ -3,6 +3,8 @@
 module Geo
   class EventWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
+
+    data_consistency :always
     include GeoQueue
     include ::Gitlab::Geo::LogHelpers
 

ee/app/workers/geo/file_download_worker.rb

@@ -3,6 +3,8 @@
 module Geo
   class FileDownloadWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
+
+    data_consistency :always
     include GeoQueue
 
     sidekiq_options retry: 3, dead: false

ee/app/workers/geo/file_registry_removal_worker.rb

@@ -4,6 +4,8 @@ module Geo
   class FileRegistryRemovalWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
     include GeoQueue
     include ::Gitlab::Geo::LogHelpers

ee/app/workers/geo/file_removal_worker.rb

@@ -4,6 +4,8 @@ module Geo
   class FileRemovalWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
     include Gitlab::Geo::LogHelpers
     include GeoQueue

ee/app/workers/geo/hashed_storage_attachments_migration_worker.rb

@@ -4,6 +4,8 @@ module Geo
   class HashedStorageAttachmentsMigrationWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
     include GeoQueue
 

ee/app/workers/geo/hashed_storage_migration_worker.rb

@@ -4,6 +4,8 @@ module Geo
   class HashedStorageMigrationWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
     include GeoQueue
 

ee/app/workers/geo/metrics_update_worker.rb

@@ -4,6 +4,8 @@ module Geo
   class MetricsUpdateWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
     include ExclusiveLeaseGuard
     # rubocop:disable Scalability/CronWorkerContext

ee/app/workers/geo/project_sync_worker.rb

@@ -3,6 +3,8 @@
 module Geo
   class ProjectSyncWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
+
+    data_consistency :always
     include GeoQueue
     include Gitlab::Geo::LogHelpers
 

ee/app/workers/geo/prune_event_log_worker.rb

@@ -4,6 +4,8 @@ module Geo
   class PruneEventLogWorker # 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

ee/app/workers/geo/rename_repository_worker.rb

@@ -4,6 +4,8 @@ module Geo
   class RenameRepositoryWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
     include GeoQueue
 

ee/app/workers/geo/repositories_clean_up_worker.rb

@@ -4,6 +4,8 @@ module Geo
   class RepositoriesCleanUpWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
     include ExclusiveLeaseGuard
     include GeoQueue

ee/app/workers/geo/repository_cleanup_worker.rb

@@ -4,6 +4,8 @@ module Geo
   class RepositoryCleanupWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
     include GeoQueue
     include ::Gitlab::Geo::LogHelpers

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

@@ -5,6 +5,8 @@ module Geo
     module Primary
       class SingleWorker # rubocop:disable Scalability/IdempotentWorker
         include ApplicationWorker
+
+        data_consistency :always
         include GeoQueue
         include ExclusiveLeaseGuard
 

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

@@ -5,6 +5,8 @@ module Geo
     module Secondary
       class SingleWorker # rubocop:disable Scalability/IdempotentWorker
         include ApplicationWorker
+
+        data_consistency :always
         include GeoQueue
         include ExclusiveLeaseGuard
         include Gitlab::Geo::ProjectLogHelpers

ee/app/workers/geo/reverification_batch_worker.rb

@@ -4,6 +4,8 @@ module Geo
   class ReverificationBatchWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
     include GeoQueue
     include LimitedCapacity::Worker

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

@@ -5,6 +5,8 @@ module Geo
     class PerShardSchedulerWorker # 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

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

@@ -5,6 +5,8 @@ module Geo
     class SchedulerWorker # rubocop:disable Scalability/IdempotentWorker
       include ApplicationWorker
 
+      data_consistency :always
+
       sidekiq_options retry: 3
       include GeoQueue
       include ExclusiveLeaseGuard

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

@@ -8,6 +8,8 @@ module Geo
     class RegistryConsistencyWorker
       include ApplicationWorker
 
+      data_consistency :always
+
       sidekiq_options retry: 3
       prepend Reenqueuer
       include ::Gitlab::Geo::LogHelpers

ee/app/workers/geo/secondary_usage_data_cron_worker.rb

@@ -6,6 +6,8 @@ module Geo
 
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
     include CronjobQueue # rubocop:disable Scalability/CronWorkerContext
     include ::Gitlab::Geo::LogHelpers

ee/app/workers/geo/sidekiq_cron_config_worker.rb

@@ -4,6 +4,8 @@ module Geo
   class SidekiqCronConfigWorker # 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

ee/app/workers/geo/sync_timeout_cron_worker.rb

@@ -4,6 +4,8 @@ module Geo
   # Fail sync for records which started syncing a long time ago
   class SyncTimeoutCronWorker
     include ApplicationWorker
+
+    data_consistency :always
     include ::Gitlab::Geo::LogHelpers
 
     # This worker does not perform work scoped to a context

ee/app/workers/geo/verification_batch_worker.rb

@@ -4,6 +4,8 @@ module Geo
   class VerificationBatchWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
     include GeoQueue
     include LimitedCapacity::Worker

ee/app/workers/geo/verification_cron_worker.rb

@@ -7,6 +7,8 @@ module Geo
   class VerificationCronWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
     include ::Gitlab::Geo::LogHelpers
 

ee/app/workers/geo/verification_timeout_worker.rb

@@ -4,6 +4,8 @@ module Geo
   # Fail verification for records which started verification a long time ago
   class VerificationTimeoutWorker
     include ApplicationWorker
+
+    data_consistency :always
     include GeoQueue
     include ::Gitlab::Geo::LogHelpers
 

ee/app/workers/geo/verification_worker.rb

@@ -3,6 +3,8 @@
 module Geo
   class VerificationWorker
     include ApplicationWorker
+
+    data_consistency :always
     include GeoQueue
     include ::Gitlab::Geo::LogHelpers
 

ee/app/workers/geo_repository_destroy_worker.rb

@@ -3,6 +3,8 @@
 class GeoRepositoryDestroyWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   include GeoQueue
   include ::Gitlab::Geo::LogHelpers

ee/app/workers/group_saml_group_sync_worker.rb

@@ -3,6 +3,8 @@
 class GroupSamlGroupSyncWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   include Gitlab::Utils::StrongMemoize
 

ee/app/workers/groups/schedule_bulk_repository_shard_moves_worker.rb

@@ -4,6 +4,8 @@ module Groups
   class ScheduleBulkRepositoryShardMovesWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
 
     idempotent!

ee/app/workers/groups/update_statistics_worker.rb

@@ -5,6 +5,8 @@ module Groups
   class UpdateStatisticsWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
 
     feature_category :source_code_management

ee/app/workers/historical_data_worker.rb

@@ -3,6 +3,8 @@
 class HistoricalDataWorker # 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

ee/app/workers/import_software_licenses_worker.rb

@@ -3,6 +3,8 @@
 class ImportSoftwareLicensesWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
 
   queue_namespace :cronjob

ee/app/workers/incident_management/apply_incident_sla_exceeded_label_worker.rb

@@ -4,6 +4,8 @@ module IncidentManagement
   class ApplyIncidentSlaExceededLabelWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
 
     idempotent!

ee/app/workers/incident_management/incident_sla_exceeded_check_worker.rb

@@ -4,6 +4,8 @@ module IncidentManagement
   class IncidentSlaExceededCheckWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
     include CronjobQueue # rubocop:disable Scalability/CronWorkerContext
 

ee/app/workers/incident_management/oncall_rotations/persist_all_rotations_shifts_job.rb

@@ -5,6 +5,8 @@ module IncidentManagement
     class PersistAllRotationsShiftsJob
       include ApplicationWorker
 
+      data_consistency :always
+
       sidekiq_options retry: 3
 
       idempotent!

ee/app/workers/incident_management/oncall_rotations/persist_shifts_job.rb

@@ -9,6 +9,8 @@ module IncidentManagement
     class PersistShiftsJob
       include ApplicationWorker
 
+      data_consistency :always
+
       sidekiq_options retry: 3
 
       idempotent!

ee/app/workers/incident_management/pending_escalations/alert_check_worker.rb

@@ -5,6 +5,8 @@ module IncidentManagement
     class AlertCheckWorker
       include ApplicationWorker
 
+      data_consistency :always
+
       urgency :high
 
       idempotent!

ee/app/workers/incident_management/pending_escalations/alert_create_worker.rb

@@ -5,6 +5,8 @@ module IncidentManagement
     class AlertCreateWorker
       include ApplicationWorker
 
+      data_consistency :always
+
       urgency :high
 
       idempotent!

ee/app/workers/incident_management/pending_escalations/schedule_check_cron_worker.rb

@@ -4,6 +4,8 @@ module IncidentManagement
   module PendingEscalations
     class ScheduleCheckCronWorker
       include ApplicationWorker
+
+      data_consistency :always
       # This worker does not perform work scoped to a context
       include CronjobQueue # rubocop:disable Scalability/CronWorkerContext
 

ee/app/workers/iterations/cadences/create_iterations_worker.rb

@@ -5,6 +5,8 @@ module Iterations
     class CreateIterationsWorker
       include ApplicationWorker
 
+      data_consistency :always
+
       idempotent!
       deduplicate :until_executed, including_scheduled: true
 

ee/app/workers/iterations/cadences/schedule_create_iterations_worker.rb

@@ -5,6 +5,8 @@ module Iterations
     class ScheduleCreateIterationsWorker
       include ApplicationWorker
 
+      data_consistency :always
+
       BATCH_SIZE = 1000
 
       idempotent!

ee/app/workers/iterations/roll_over_issues_worker.rb

@@ -4,6 +4,8 @@ module Iterations
   class RollOverIssuesWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     BATCH_SIZE = 1000
 
     idempotent!

ee/app/workers/iterations_update_status_worker.rb

@@ -3,6 +3,8 @@
 class IterationsUpdateStatusWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   BATCH_SIZE = 1000
 

ee/app/workers/ldap_all_groups_sync_worker.rb

@@ -3,6 +3,8 @@
 class LdapAllGroupsSyncWorker # 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

ee/app/workers/ldap_group_sync_worker.rb

@@ -3,6 +3,8 @@
 class LdapGroupSyncWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
 
   feature_category :authentication_and_authorization

ee/app/workers/ldap_sync_worker.rb

@@ -3,6 +3,8 @@
 class LdapSyncWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   include CronjobQueue # rubocop:disable Scalability/CronWorkerContext
 

ee/app/workers/merge_request_reset_approvals_worker.rb

@@ -3,6 +3,8 @@
 class MergeRequestResetApprovalsWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
 
   feature_category :source_code_management

ee/app/workers/merge_requests/sync_code_owner_approval_rules_worker.rb

@@ -4,6 +4,8 @@ module MergeRequests
   class SyncCodeOwnerApprovalRulesWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
 
     feature_category :source_code_management

ee/app/workers/merge_trains/refresh_worker.rb

@@ -4,6 +4,8 @@ module MergeTrains
   class RefreshWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
 
     queue_namespace :auto_merge

ee/app/workers/network_policy_metrics_worker.rb

@@ -6,6 +6,8 @@
 class NetworkPolicyMetricsWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
 
   queue_namespace :cronjob

ee/app/workers/new_epic_worker.rb

@@ -3,6 +3,8 @@
 class NewEpicWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   include NewIssuable
 

ee/app/workers/personal_access_tokens/groups/policy_worker.rb

@@ -5,6 +5,8 @@ module PersonalAccessTokens
     class PolicyWorker
       include ApplicationWorker
 
+      data_consistency :always
+
       sidekiq_options retry: 3
 
       idempotent!

ee/app/workers/personal_access_tokens/instance/policy_worker.rb

@@ -5,6 +5,8 @@ module PersonalAccessTokens
     class PolicyWorker # rubocop:disable Scalability/IdempotentWorker
       include ApplicationWorker
 
+      data_consistency :always
+
       sidekiq_options retry: 3
 
       queue_namespace :personal_access_tokens

ee/app/workers/project_import_schedule_worker.rb

@@ -4,6 +4,8 @@ class ProjectImportScheduleWorker
   ImportStateNotFound = Class.new(StandardError)
 
   include ApplicationWorker
+
+  data_consistency :always
   prepend WaitableWorker
 
   idempotent!

ee/app/workers/pseudonymizer_worker.rb

@@ -3,6 +3,8 @@
 class PseudonymizerWorker # 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

ee/app/workers/refresh_license_compliance_checks_worker.rb

@@ -3,6 +3,8 @@
 class RefreshLicenseComplianceChecksWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
 
   feature_category :license_compliance

ee/app/workers/repository_push_audit_event_worker.rb

@@ -3,6 +3,8 @@
 class RepositoryPushAuditEventWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
 
   feature_category :authentication_and_authorization

ee/app/workers/repository_update_mirror_worker.rb

@@ -4,6 +4,8 @@ class RepositoryUpdateMirrorWorker # rubocop:disable Scalability/IdempotentWorke
   UpdateError = Class.new(StandardError)
 
   include ApplicationWorker
+
+  data_consistency :always
   include Gitlab::ShellAdapter
   include ProjectStartImport
 

ee/app/workers/requirements_management/import_requirements_csv_worker.rb

@@ -4,6 +4,8 @@ module RequirementsManagement
   class ImportRequirementsCsvWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
     include Gitlab::Utils::StrongMemoize
 

ee/app/workers/requirements_management/process_requirements_reports_worker.rb

@@ -4,6 +4,8 @@ module RequirementsManagement
   class ProcessRequirementsReportsWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
 
     feature_category :requirements_management

ee/app/workers/scan_security_report_secrets_worker.rb

@@ -5,6 +5,8 @@
 class ScanSecurityReportSecretsWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   queue_namespace :security_scans
   feature_category :secret_detection
 

ee/app/workers/security/auto_fix_worker.rb

@@ -4,6 +4,8 @@ module Security
   class AutoFixWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
 
     feature_category :vulnerability_management

ee/app/workers/security/create_orchestration_policy_worker.rb

@@ -3,6 +3,8 @@
 module Security
   class CreateOrchestrationPolicyWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
+
+    data_consistency :always
     # rubocop:disable Scalability/CronWorkerContext
     # This worker does not perform work scoped to a context
     include CronjobQueue

ee/app/workers/security/orchestration_policy_rule_schedule_worker.rb

@@ -3,6 +3,8 @@
 module Security
   class OrchestrationPolicyRuleScheduleWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
+
+    data_consistency :always
     # rubocop:disable Scalability/CronWorkerContext
     # This worker does not perform work scoped to a context
     include CronjobQueue

ee/app/workers/security/store_scans_worker.rb

@@ -4,6 +4,8 @@ module Security
   class StoreScansWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
     include SecurityScansQueue
 

ee/app/workers/security/track_secure_scans_worker.rb

@@ -7,7 +7,7 @@ module Security
     include SecurityScansQueue
 
     sidekiq_options retry: 1
-
+    data_consistency :always
     worker_resource_boundary :cpu
 
     def perform(build_id)

ee/app/workers/set_user_status_based_on_user_cap_setting_worker.rb

@@ -3,6 +3,8 @@
 class SetUserStatusBasedOnUserCapSettingWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   include ::Gitlab::Utils::StrongMemoize
 

ee/app/workers/status_page/publish_worker.rb

@@ -3,6 +3,8 @@
 module StatusPage
   class PublishWorker
     include ApplicationWorker
+
+    data_consistency :always
     include Gitlab::Utils::StrongMemoize
 
     sidekiq_options retry: 5

ee/app/workers/store_security_reports_worker.rb

@@ -5,6 +5,8 @@
 class StoreSecurityReportsWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   include SecurityScansQueue
 

ee/app/workers/store_security_scans_worker.rb

@@ -3,6 +3,8 @@
 class StoreSecurityScansWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   include SecurityScansQueue
 

ee/app/workers/sync_seat_link_request_worker.rb

@@ -3,6 +3,8 @@
 class SyncSeatLinkRequestWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   feature_category :license
 
   # Retry for up to approximately 6 days

ee/app/workers/sync_seat_link_worker.rb

@@ -2,6 +2,8 @@
 
 class SyncSeatLinkWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
+
+  data_consistency :always
   # rubocop:disable Scalability/CronWorkerContext
   # This worker does not perform work scoped to a context
   include CronjobQueue

ee/app/workers/todos_destroyer/confidential_epic_worker.rb

@@ -4,6 +4,8 @@ module TodosDestroyer
   class ConfidentialEpicWorker # rubocop:disable Scalability/IdempotentWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
 
     queue_namespace :todos_destroyer

ee/app/workers/update_max_seats_used_for_gitlab_com_subscriptions_worker.rb

@@ -3,6 +3,8 @@
 class UpdateMaxSeatsUsedForGitlabComSubscriptionsWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
+  data_consistency :always
+
   sidekiq_options retry: 3
   include CronjobQueue # rubocop:disable Scalability/CronWorkerContext
 

ee/app/workers/vulnerabilities/historical_statistics/deletion_worker.rb

@@ -5,6 +5,8 @@ module Vulnerabilities
     class DeletionWorker # 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

ee/app/workers/vulnerabilities/statistics/adjustment_worker.rb

@@ -5,6 +5,8 @@ module Vulnerabilities
     class AdjustmentWorker # rubocop:disable Scalability/IdempotentWorker
       include ApplicationWorker
 
+      data_consistency :always
+
       sidekiq_options retry: 3
 
       feature_category :vulnerability_management

ee/app/workers/vulnerabilities/statistics/schedule_worker.rb

@@ -5,6 +5,8 @@ module Vulnerabilities
     class ScheduleWorker # 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

ee/app/workers/vulnerability_exports/export_deletion_worker.rb

@@ -4,6 +4,8 @@ module VulnerabilityExports
   class ExportDeletionWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
 
     feature_category :vulnerability_management

ee/app/workers/vulnerability_exports/export_worker.rb

@@ -4,6 +4,8 @@ module VulnerabilityExports
   class ExportWorker
     include ApplicationWorker
 
+    data_consistency :always
+
     sidekiq_options retry: 3
     include ::Gitlab::ExclusiveLeaseHelpers