Migrate new jobs when reverting pipeline queues migration

1 files changed, 7 insertions, 2 deletions

diff --git a/spec/migrations/migrate_pipeline_sidekiq_queues_spec.rb b/spec/migrations/migrate_pipeline_sidekiq_queues_spec.rb
index fff531a78c5..e02bcd2f4da 100644
--- a/spec/migrations/migrate_pipeline_sidekiq_queues_spec.rb
+++ b/spec/migrations/migrate_pipeline_sidekiq_queues_spec.rb
@@ -21,12 +21,17 @@ describe MigratePipelineSidekiqQueues, :sidekiq, :redis do
     it 'correctly migrates queue when migrating down' do
       Sidekiq::Testing.disable! do
         stubbed_worker(queue: :pipeline_default).perform_async('Class', [1])
-        stubbed_worker(queue: :pipeline_default).perform_async('Class', [2])
+        stubbed_worker(queue: :pipeline_processing).perform_async('Class', [2])
+        stubbed_worker(queue: :pipeline_hooks).perform_async('Class', [3])
+        stubbed_worker(queue: :pipeline_cache).perform_async('Class', [4])
 
         described_class.new.down
 
-        expect(sidekiq_queue_length('pipeline')).to eq 2
+        expect(sidekiq_queue_length('pipeline')).to eq 4
         expect(sidekiq_queue_length('pipeline_default')).to eq 0
+        expect(sidekiq_queue_length('pipeline_processing')).to eq 0
+        expect(sidekiq_queue_length('pipeline_hooks')).to eq 0
+        expect(sidekiq_queue_length('pipeline_cache')).to eq 0
       end
     end
   end