summaryrefslogtreecommitdiff
path: root/db
diff options
context:
space:
mode:
authorGrzegorz Bizon <grzesiek.bizon@gmail.com>2017-06-30 13:03:47 +0200
committerGrzegorz Bizon <grzesiek.bizon@gmail.com>2017-07-07 15:08:15 +0200
commit3408157155924e7bc817960767f69cc1fce9a5a5 (patch)
tree7a910a330d843decc46bdb48f3a82e2039a7f91d /db
parent84d9789d57edf1c09b8a63bbd4f455c9ee437aa7 (diff)
downloadgitlab-ce-3408157155924e7bc817960767f69cc1fce9a5a5.tar.gz
Do not override original AR5 batching interface
Diffstat (limited to 'db')
-rw-r--r--db/post_migrate/20170628080858_migrate_stage_id_reference_in_background.rb7
1 files changed, 5 insertions, 2 deletions
diff --git a/db/post_migrate/20170628080858_migrate_stage_id_reference_in_background.rb b/db/post_migrate/20170628080858_migrate_stage_id_reference_in_background.rb
index 1d95fc62c87..30849ea1361 100644
--- a/db/post_migrate/20170628080858_migrate_stage_id_reference_in_background.rb
+++ b/db/post_migrate/20170628080858_migrate_stage_id_reference_in_background.rb
@@ -12,9 +12,12 @@ class MigrateStageIdReferenceInBackground < ActiveRecord::Migration
end
def up
- Build.where(stage_id: nil).in_batches(of: BATCH_SIZE) do |relation, index|
- schedule = index * 5.minutes
+ index = 1
+
+ Build.where(stage_id: nil).in_batches(of: BATCH_SIZE) do |relation|
jobs = relation.pluck(:id).map { |id| [MIGRATION, [id]] }
+ schedule = index * 5.minutes
+ index += 1
BackgroundMigrationWorker.perform_bulk_in(schedule, jobs)
end