bug(#2165): Fix migration for adapter instances (#2167)

apache · Nov 13, 2023 · 18cdb2d · 18cdb2d
1 parent 1306e79
commit 18cdb2d
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/...e/src/main/java/org/apache/streampipes/service/core/migrations/v093/AdapterMigration.java b/...e/src/main/java/org/apache/streampipes/service/core/migrations/v093/AdapterMigration.java
@@ -111,7 +111,9 @@ public void executeMigration() {
     LOG.info("Performing backup of old models to database adapterinstance_backup");
 
     adaptersToMigrate.forEach(adapter -> {
-      new AdapterBackupWriter(adapterInstanceBackupClient, new MigrationHelpers()).writeBackup(adapter);
+      // Is required to keep the _rev field for the original object. This field must be removed for the backup
+      var copyAdapter = adapter.deepCopy();
+      new AdapterBackupWriter(adapterInstanceBackupClient, new MigrationHelpers()).writeBackup(copyAdapter);
     });
 
     LOG.info("Performing migration of adapters");

diff --git a/...org/apache/streampipes/service/core/migrations/v093/migrator/SpecificAdapterMigrator.java b/...org/apache/streampipes/service/core/migrations/v093/migrator/SpecificAdapterMigrator.java
@@ -44,6 +44,8 @@ public void migrate(CouchDbClient couchDbClient,
     var adapterName = helpers.getAdapterName(adapter);
     var convertedAdapter = converter.convert(adapter);
 
+    LOG.info("Start migrating adapter {}", adapterName);
+
     couchDbClient.update(convertedAdapter);
 
     LOG.info("Successfully migrated adapter {}", adapterName);