Merge branch 'lm-update-pipeline-notification-worker-to-use-replica' into 'master'

Add data consistency for PipelineNotificationWorker

See merge request gitlab-org/gitlab!66459

app/workers/pipeline_notification_worker.rb

@@ -3,13 +3,12 @@
 class PipelineNotificationWorker # rubocop:disable Scalability/IdempotentWorker
   include ApplicationWorker
 
-  data_consistency :always
-
   sidekiq_options retry: 3
   include PipelineQueue
 
   urgency :high
   worker_resource_boundary :cpu
+  data_consistency :delayed, feature_flag: :load_balancing_for_pipeline_notification_worker
 
   def perform(pipeline_id, args = {})
     case args

config/feature_flags/development/load_balancing_for_pipeline_notification_worker.yml

+---
+name: load_balancing_for_pipeline_notification_worker
+introduced_by_url: https://gitlab.com/gitlab-org/gitlab/-/merge_requests/66459
+rollout_issue_url: https://gitlab.com/gitlab-org/gitlab/-/issues/336517
+milestone: '14.2'
+type: development
+group: group::pipeline authoring
+default_enabled: false
+

spec/workers/pipeline_notification_worker_spec.rb

@@ -20,5 +20,10 @@ RSpec.describe PipelineNotificationWorker, :mailer do
 
       subject.perform(non_existing_record_id)
     end
+
+    it_behaves_like 'worker with data consistency',
+      described_class,
+      feature_flag: :load_balancing_for_pipeline_notification_worker,
+      data_consistency: :delayed
   end
 end