Fix Elastic::MigrationWorker current_migration

Changelog: fixed EE: true

Fix Elastic::MigrationWorker current_migration
Changelog: fixed EE: true
f682052a · Dmitry Gruzd · 2c1838e7 · f682052a · f682052a
Commit f682052a authored Sep 09, 2021 by Dmitry Gruzd
Showing with 136 additions and 120 deletions

ee/app/workers/elastic/migration_worker.rb ee/app/workers/elastic/migration_worker.rb +2 -2

ee/spec/workers/elastic/migration_worker_spec.rb ee/spec/workers/elastic/migration_worker_spec.rb +134 -118

No files found.
--- a/ee/app/workers/elastic/migration_worker.rb
+++ b/ee/app/workers/elastic/migration_worker.rb
@@ -87,9 +87,9 @@ module Elastic
    end

    def current_migration
-      completed_migrations = Elastic::MigrationRecord.load_versions(completed: true)
+      uncompleted_migrations = Elastic::MigrationRecord.load_versions(completed: false)

-      Elastic::DataMigrationService.migrations.find { |migration| !completed_migrations.include?(migration.version) }
+      Elastic::DataMigrationService.migrations.find { |migration| uncompleted_migrations.include?(migration.version) }
    end

    def pause_indexing!(migration)

--- a/ee/spec/workers/elastic/migration_worker_spec.rb
+++ b/ee/spec/workers/elastic/migration_worker_spec.rb