summaryrefslogtreecommitdiff
path: root/spec
diff options
context:
space:
mode:
authorKamil Trzciński <ayufan@ayufan.eu>2017-09-19 13:38:07 +0000
committerKamil Trzciński <ayufan@ayufan.eu>2017-09-19 13:38:07 +0000
commit0cd46457bdbe3cf36421755dab8b59d830d77b62 (patch)
tree6c8009cad024e6a8e068a3ed2a03a0fb95539539 /spec
parent4c6c105909ea610eac760b05e66d9efc57cbb43c (diff)
parent73d31251af6e0574423990836e56350b8ffbea41 (diff)
downloadgitlab-ce-0cd46457bdbe3cf36421755dab8b59d830d77b62.tar.gz
Merge branch 'backstage/gb/steal-stages-statuses-migration' into 'master'
Steal stages statuses migration Closes #37694 See merge request gitlab-org/gitlab-ce!14217
Diffstat (limited to 'spec')
-rw-r--r--spec/migrations/clean_stages_statuses_migration_spec.rb51
1 files changed, 51 insertions, 0 deletions
diff --git a/spec/migrations/clean_stages_statuses_migration_spec.rb b/spec/migrations/clean_stages_statuses_migration_spec.rb
new file mode 100644
index 00000000000..38705f8eaae
--- /dev/null
+++ b/spec/migrations/clean_stages_statuses_migration_spec.rb
@@ -0,0 +1,51 @@
+require 'spec_helper'
+require Rails.root.join('db', 'migrate', '20170912113435_clean_stages_statuses_migration.rb')
+
+describe CleanStagesStatusesMigration, :migration, :sidekiq, :redis do
+ let(:migration) { spy('migration') }
+
+ before do
+ allow(Gitlab::BackgroundMigration::MigrateStageStatus)
+ .to receive(:new).and_return(migration)
+ end
+
+ context 'when there are pending background migrations' do
+ it 'processes pending jobs synchronously' do
+ Sidekiq::Testing.disable! do
+ BackgroundMigrationWorker
+ .perform_in(2.minutes, 'MigrateStageStatus', [1, 1])
+ BackgroundMigrationWorker
+ .perform_async('MigrateStageStatus', [1, 1])
+
+ migrate!
+
+ expect(migration).to have_received(:perform).with(1, 1).twice
+ end
+ end
+ end
+
+ context 'when there are no background migrations pending' do
+ it 'does nothing' do
+ Sidekiq::Testing.disable! do
+ migrate!
+
+ expect(migration).not_to have_received(:perform)
+ end
+ end
+ end
+
+ context 'when there are still unmigrated stages afterwards' do
+ let(:stages) { table('ci_stages') }
+
+ before do
+ stages.create!(status: nil, name: 'build')
+ stages.create!(status: nil, name: 'test')
+ end
+
+ it 'migrates statuses sequentially in batches' do
+ migrate!
+
+ expect(migration).to have_received(:perform).once
+ end
+ end
+end