1 files changed, 24 insertions, 6 deletions
diff --git a/spec/services/ci/play_bridge_service_spec.rb b/spec/services/ci/play_bridge_service_spec.rb
index 3f97bfdf5ae..665f25de299 100644
--- a/spec/services/ci/play_bridge_service_spec.rb
+++ b/spec/services/ci/play_bridge_service_spec.rb
@@ -23,18 +23,36 @@ RSpec.describe Ci::PlayBridgeService, '#execute' do
       expect(bridge.reload).to be_pending
     end
 
-    it 'enqueues Ci::CreateCrossProjectPipelineWorker' do
-      expect(::Ci::CreateCrossProjectPipelineWorker).to receive(:perform_async).with(bridge.id)
-
-      execute_service
-    end
-
     it "updates bridge's user" do
       execute_service
 
       expect(bridge.reload.user).to eq(user)
     end
 
+    context 'when the create_cross_project_pipeline_worker_rename feature is enabled' do
+      before do
+        stub_feature_flags(create_cross_project_pipeline_worker_rename: true)
+      end
+
+      it 'enqueues Ci::CreateDownstreamPipelineWorker' do
+        expect(::Ci::CreateDownstreamPipelineWorker).to receive(:perform_async).with(bridge.id)
+
+        execute_service
+      end
+    end
+
+    context 'when the create_cross_project_pipeline_worker_rename feature is not enabled' do
+      before do
+        stub_feature_flags(create_cross_project_pipeline_worker_rename: false)
+      end
+
+      it 'enqueues Ci::CreateCrossProjectPipelineWorker' do
+        expect(::Ci::CreateCrossProjectPipelineWorker).to receive(:perform_async).with(bridge.id)
+
+        execute_service
+      end
+    end
+
     context 'when a subsequent job is skipped' do
       let!(:job) { create(:ci_build, :skipped, pipeline: pipeline, stage_idx: bridge.stage_idx + 1) }