aboutsummaryrefslogtreecommitdiffstats
path: root/openecomp-be/tools/migration
diff options
context:
space:
mode:
Diffstat (limited to 'openecomp-be/tools/migration')
-rw-r--r--openecomp-be/tools/migration/1702_to_1707_zusammen/pom.xml2
-rw-r--r--openecomp-be/tools/migration/1702_to_1707_zusammen/src/main/java/org/openecomp/core/migration/MigrationMain.java5
2 files changed, 4 insertions, 3 deletions
diff --git a/openecomp-be/tools/migration/1702_to_1707_zusammen/pom.xml b/openecomp-be/tools/migration/1702_to_1707_zusammen/pom.xml
index 7bc93bddab..1f281c950b 100644
--- a/openecomp-be/tools/migration/1702_to_1707_zusammen/pom.xml
+++ b/openecomp-be/tools/migration/1702_to_1707_zusammen/pom.xml
@@ -47,7 +47,7 @@
<dependency>
<groupId>com.amdocs.zusammen.plugin</groupId>
<artifactId>zusammen-state-store-cassandra-plugin</artifactId>
- <version>0.0.1-SNAPSHOT</version>
+ <version>0.0.1</version>
</dependency>
<dependency>
<groupId>org.hibernate</groupId>
diff --git a/openecomp-be/tools/migration/1702_to_1707_zusammen/src/main/java/org/openecomp/core/migration/MigrationMain.java b/openecomp-be/tools/migration/1702_to_1707_zusammen/src/main/java/org/openecomp/core/migration/MigrationMain.java
index 283c9cf25d..c43cf32001 100644
--- a/openecomp-be/tools/migration/1702_to_1707_zusammen/src/main/java/org/openecomp/core/migration/MigrationMain.java
+++ b/openecomp-be/tools/migration/1702_to_1707_zusammen/src/main/java/org/openecomp/core/migration/MigrationMain.java
@@ -78,7 +78,7 @@ public class MigrationMain {
printMessage(logger, "Checking whether a migration has already been run.");
if (MigrationMarker.isMigrated()) {
printMessage(logger, "The DB has already been migrated, this script will now exit.");
- return;
+ System.exit(status);
}
ItemCassandraDao itemCassandraDao = new ItemCassandraDao();
VersionCassandraDao versionCassandraDao = new VersionCassandraDao();
@@ -243,7 +243,8 @@ public class MigrationMain {
new OrchestrationTemplateCandidateCassandraLoader();
orchestrationTemplateCandidateCassandraLoader.list().stream()
- .filter(entity -> needMigration(entity.getId(), entity.getVersion()))
+ .filter(entity -> needMigration(entity.getId(), entity.getVersion()) &&
+ entity.getContentData()!=null && entity.getFilesDataStructure()!=null)
.forEach(entity -> ElementHandler
.save(context, cassandraElementRepository, entity.getId(), entity.getVersion(),
OrchestrationTemplateCandidateConvertor