Put checks for when legacyStudyFqnToValue is empty

openlattice · Feb 16, 2022 · b6236c9 · b6236c9
1 parent 3f1dc32
commit b6236c9
Showing 1 changed file with 19 additions and 17 deletions.
diff --git a/src/main/kotlin/com/openlattice/mechanic/upgrades/V3StudyMigrationUpgrade.kt b/src/main/kotlin/com/openlattice/mechanic/upgrades/V3StudyMigrationUpgrade.kt
@@ -175,25 +175,27 @@ class V3StudyMigrationUpgrade(
                     Optional.empty(),
                     false
             ).forEach { (legacyStudyEkid, legacyStudyFqnToValue) ->
-                logger.info("Processing all legacy participants of $legacyStudyEkid")
-                try {
-                    entitySets.keySet(
-                        Predicates.equal<UUID, EntitySet>("name", "chronicle_participants_${legacyStudyFqnToValue[FullQualifiedName("general.stringid")]!!.first()}")
-                    ).forEach { participantESID ->
-                        dataQueryService.getEntitiesWithPropertyTypeFqns(
-                            mapOf(participantESID to Optional.of(setOf<UUID>())),
-                            mapOf(participantESID to legacyParticipantPropertyTypes),
-                            emptyMap(),
-                            EnumSet.noneOf(MetadataOption::class.java),
-                            Optional.empty(),
-                            false
-                        ).forEach { (_, legacyParticipantFqnToValue) ->
-                            logger.info("Inserting participant: $legacyParticipantFqnToValue into candidates")
-                            insertIntoCandidatesTable(connection, legacyStudyEkid, legacyParticipantFqnToValue)
+                logger.info("Processing all legacy participants of $legacyStudyEkid, with stringid ${legacyStudyFqnToValue.getOrDefault(FullQualifiedName("general.stringid"), null)}")
+                if (legacyStudyFqnToValue.isNotEmpty()) {
+                    try {
+                        entitySets.keySet(
+                            Predicates.equal<UUID, EntitySet>("name", "chronicle_participants_${legacyStudyFqnToValue.getOrDefault(FullQualifiedName("general.stringid"), null)}")
+                        ).forEach { participantESID ->
+                            dataQueryService.getEntitiesWithPropertyTypeFqns(
+                                mapOf(participantESID to Optional.of(setOf<UUID>())),
+                                mapOf(participantESID to legacyParticipantPropertyTypes),
+                                emptyMap(),
+                                EnumSet.noneOf(MetadataOption::class.java),
+                                Optional.empty(),
+                                false
+                            ).forEach { (_, legacyParticipantFqnToValue) ->
+                                logger.info("Inserting participant: $legacyParticipantFqnToValue into candidates")
+                                insertIntoCandidatesTable(connection, legacyStudyEkid, legacyParticipantFqnToValue)
+                            }
                         }
+                    } catch (ex: Exception) {
+                        logger.error("An error occurred processing legacy participants of $legacyStudyEkid", ex)
                     }
-                } catch (ex: Exception) {
-                    logger.error("An error occurred processing legacy participants of $legacyStudyEkid", ex)
                 }
             }
         }