Revert "#110 | Optimize schemaMigration to be updated only if there a…

…re changes" This reverts commit 0fbc2cd.
avniproject · Jan 8, 2025 · d233d7e · d233d7e
1 parent 0fbc2cd
commit d233d7e
Showing 1 changed file with 6 additions and 5 deletions.
diff --git a/src/main/java/org/avniproject/etl/service/SchemaMigrationService.java b/src/main/java/org/avniproject/etl/service/SchemaMigrationService.java
@@ -36,11 +36,12 @@ public Organisation migrate(Organisation organisation) {
         SchemaMetadata newSchemaMetadata = schemaMetadataRepository.getNewSchemaMetadata();
 
         List<Diff> changes = newSchemaMetadata.findChanges(organisation.getSchemaMetadata());
-        if(!changes.isEmpty()) {
-            schemaMetadataRepository.applyChanges(changes);
-            organisation.applyNewSchema(newSchemaMetadata);
-            schemaMetadataRepository.save(organisation.getSchemaMetadata());
-        }
+        schemaMetadataRepository.applyChanges(changes);
+
+        organisation.applyNewSchema(newSchemaMetadata);
+
+        schemaMetadataRepository.save(organisation.getSchemaMetadata());
+
         return organisation;
     }