diff --git a/package-toolkit/runtime/src/main/kotlin/com/atlan/pkg/util/AssetResolver.kt b/package-toolkit/runtime/src/main/kotlin/com/atlan/pkg/util/AssetResolver.kt index e05aff0bf0..1b2f51f137 100644 --- a/package-toolkit/runtime/src/main/kotlin/com/atlan/pkg/util/AssetResolver.kt +++ b/package-toolkit/runtime/src/main/kotlin/com/atlan/pkg/util/AssetResolver.kt @@ -19,7 +19,7 @@ interface AssetResolver { fun getConnectionIdentityFromQN(agnosticQualifiedName: String): ConnectionIdentity? { val tokens = agnosticQualifiedName.split("/") return if (tokens.size > 1) { - ConnectionIdentity(tokens[0], tokens[1]) + ConnectionIdentity(tokens[0], tokens[1].lowercase()) } else { null } diff --git a/samples/packages/cube-assets-builder/src/main/kotlin/com/atlan/pkg/cab/AssetImporter.kt b/samples/packages/cube-assets-builder/src/main/kotlin/com/atlan/pkg/cab/AssetImporter.kt index 0230687c61..0d3aecf4c8 100644 --- a/samples/packages/cube-assets-builder/src/main/kotlin/com/atlan/pkg/cab/AssetImporter.kt +++ b/samples/packages/cube-assets-builder/src/main/kotlin/com/atlan/pkg/cab/AssetImporter.kt @@ -90,7 +90,7 @@ abstract class AssetImporter( when (typeName) { Connection.TYPE_NAME -> { val connection = CSVXformer.trimWhitespace(row[header.indexOf(Asset.CONNECTION_NAME.atlanFieldName)]) - val connector = CSVXformer.trimWhitespace(row[header.indexOf(ConnectionImporter.CONNECTOR_TYPE)]) + val connector = CSVXformer.trimWhitespace(row[header.indexOf(ConnectionImporter.CONNECTOR_TYPE)]).lowercase() parent = null unique = ConnectionIdentity(connection, connector).toString() partial = "" diff --git a/samples/packages/cube-assets-builder/src/main/kotlin/com/atlan/pkg/cab/Importer.kt b/samples/packages/cube-assets-builder/src/main/kotlin/com/atlan/pkg/cab/Importer.kt index 426fbc2839..d5cf2f7e7f 100644 --- a/samples/packages/cube-assets-builder/src/main/kotlin/com/atlan/pkg/cab/Importer.kt +++ b/samples/packages/cube-assets-builder/src/main/kotlin/com/atlan/pkg/cab/Importer.kt @@ -171,7 +171,7 @@ object Importer { } if (connectionIdentity == null) { val name = row.getOrNull(header.indexOf("connectionName")) - val type = row.getOrNull(header.indexOf("connectorType")) + val type = row.getOrNull(header.indexOf("connectorType"))?.lowercase() if (name != null && type != null) { connectionIdentity = AssetResolver.ConnectionIdentity(name, type) } diff --git a/samples/packages/lineage-builder/src/main/kotlin/com/atlan/pkg/lb/AssetTransformer.kt b/samples/packages/lineage-builder/src/main/kotlin/com/atlan/pkg/lb/AssetTransformer.kt index 9f48613e1f..55f331d3a8 100644 --- a/samples/packages/lineage-builder/src/main/kotlin/com/atlan/pkg/lb/AssetTransformer.kt +++ b/samples/packages/lineage-builder/src/main/kotlin/com/atlan/pkg/lb/AssetTransformer.kt @@ -56,7 +56,7 @@ class AssetTransformer( inputRow: Map, prefix: String, ): String { - val connectorType = inputRow["$prefix $CONNECTOR"] ?: "" + val connectorType = inputRow["$prefix $CONNECTOR"]?.lowercase() ?: "" val connectionName = inputRow["$prefix $CONNECTION"] ?: "" val connectionId = AssetResolver.ConnectionIdentity(connectionName, connectorType) return ctx.connectionCache.getIdentityMap().getOrDefault(connectionId, "") @@ -117,7 +117,7 @@ class AssetTransformer( assetQN, inputRow["$prefix $TYPE"] ?: "", inputRow["$prefix $NAME"] ?: "", - inputRow["$prefix $CONNECTOR"] ?: "", + inputRow["$prefix $CONNECTOR"]?.lowercase() ?: "", connectionQN, ) } else { diff --git a/samples/packages/lineage-builder/src/main/kotlin/com/atlan/pkg/lb/LineageTransformer.kt b/samples/packages/lineage-builder/src/main/kotlin/com/atlan/pkg/lb/LineageTransformer.kt index f4e6699b2f..29c17ff24b 100644 --- a/samples/packages/lineage-builder/src/main/kotlin/com/atlan/pkg/lb/LineageTransformer.kt +++ b/samples/packages/lineage-builder/src/main/kotlin/com/atlan/pkg/lb/LineageTransformer.kt @@ -65,7 +65,7 @@ class LineageTransformer( if (source !is ICatalog || target !is ICatalog) { logger.warn { "Source and/or target asset are not subtypes of Catalog, and therefore cannot exist in lineage: $inputRow" } } else { - val xformConnector = inputRow[XFORM_CONNECTOR] ?: "" + val xformConnector = inputRow[XFORM_CONNECTOR]?.lowercase() ?: "" val xformConnection = inputRow[XFORM_CONNECTION] ?: "" val connectionId = AssetResolver.ConnectionIdentity(xformConnection, xformConnector) val connectionQN = ctx.connectionCache.getIdentityMap().getOrDefault(connectionId, "") diff --git a/samples/packages/relational-assets-builder/src/main/kotlin/com/atlan/pkg/rab/AssetImporter.kt b/samples/packages/relational-assets-builder/src/main/kotlin/com/atlan/pkg/rab/AssetImporter.kt index 0baf929c38..48d33fd2ee 100644 --- a/samples/packages/relational-assets-builder/src/main/kotlin/com/atlan/pkg/rab/AssetImporter.kt +++ b/samples/packages/relational-assets-builder/src/main/kotlin/com/atlan/pkg/rab/AssetImporter.kt @@ -93,7 +93,7 @@ abstract class AssetImporter( when (typeName) { Connection.TYPE_NAME -> { val connection = CSVXformer.trimWhitespace(row[header.indexOf(Asset.CONNECTION_NAME.atlanFieldName)]) - val connector = CSVXformer.trimWhitespace(row[header.indexOf(ConnectionImporter.CONNECTOR_TYPE)]) + val connector = CSVXformer.trimWhitespace(row[header.indexOf(ConnectionImporter.CONNECTOR_TYPE)]).lowercase() current = ConnectionIdentity(connection, connector).toString() parent = null }