20170627101016_schedule_event_migrations.rb 1.02 KB
Newer Older
1 2 3
# See http://doc.gitlab.com/ce/development/migration_style_guide.html
# for more information on how to write migrations for GitLab.

4
class ScheduleEventMigrations < ActiveRecord::Migration[4.2]
5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27
  include Gitlab::Database::MigrationHelpers

  DOWNTIME = false
  BUFFER_SIZE = 1000

  disable_ddl_transaction!

  class Event < ActiveRecord::Base
    include EachBatch

    self.table_name = 'events'
  end

  def up
    jobs = []

    Event.each_batch(of: 1000) do |relation|
      min, max = relation.pluck('MIN(id), MAX(id)').first

      if jobs.length == BUFFER_SIZE
        # We push multiple jobs at a time to reduce the time spent in
        # Sidekiq/Redis operations. We're using this buffer based approach so we
        # don't need to run additional queries for every range.
28
        BackgroundMigrationWorker.bulk_perform_async(jobs)
29 30 31 32 33 34
        jobs.clear
      end

      jobs << ['MigrateEventsToPushEventPayloads', [min, max]]
    end

35
    BackgroundMigrationWorker.bulk_perform_async(jobs) unless jobs.empty?
36 37 38 39 40
  end

  def down
  end
end