Welcome to mirror list, hosted at ThFree Co, Russian Federation.

gitlab.com/gitlab-org/gitlab-foss.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
Diffstat (limited to 'db/post_migrate/20230214154101_fix_partition_ids_on_ci_sources_pipelines.rb')
-rw-r--r--db/post_migrate/20230214154101_fix_partition_ids_on_ci_sources_pipelines.rb27
1 files changed, 1 insertions, 26 deletions
diff --git a/db/post_migrate/20230214154101_fix_partition_ids_on_ci_sources_pipelines.rb b/db/post_migrate/20230214154101_fix_partition_ids_on_ci_sources_pipelines.rb
index c05b759c2d0..bbacd13389b 100644
--- a/db/post_migrate/20230214154101_fix_partition_ids_on_ci_sources_pipelines.rb
+++ b/db/post_migrate/20230214154101_fix_partition_ids_on_ci_sources_pipelines.rb
@@ -1,36 +1,11 @@
# frozen_string_literal: true
class FixPartitionIdsOnCiSourcesPipelines < Gitlab::Database::Migration[2.1]
- disable_ddl_transaction!
- restrict_gitlab_migration gitlab_schema: :gitlab_ci
-
- BATCH_SIZE = 50
-
def up
- return unless Gitlab.com?
-
- model = define_batchable_model(:ci_sources_pipelines)
-
- batch_update_records(model, :partition_id, from: 101, to: 100, source_partition_id: 100)
- batch_update_records(model, :source_partition_id, from: 101, to: 100)
+ # no-op
end
def down
# no-op
end
-
- private
-
- def batch_update_records(model, column, from:, to:, **updates)
- updates.reverse_merge!(column => to)
-
- model
- .where(model.arel_table[column].eq(from))
- .each_batch(of: BATCH_SIZE) { |batch| update_records(batch, updates) }
- end
-
- def update_records(relation, updates)
- relation.update_all(updates)
- sleep 0.1
- end
end