Skip to content

Commit fc65388

Browse files
committed
fix generated connector name to simplify redis search
Redis search have a hard time with dot(.)
1 parent 5dcf9be commit fc65388

File tree

2 files changed

+10
-2
lines changed

2 files changed

+10
-2
lines changed

dataset/src/integrationTest/kotlin/com/cosmotech/dataset/service/DatasetServiceIntegrationTest.kt

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -888,6 +888,15 @@ class DatasetServiceIntegrationTest : CsmRedisTestBase() {
888888
.linkedDatasetIdList)
889889
}
890890

891+
@Test
892+
fun `getConnector return same connector`() {
893+
val dataset = makeDatasetWithRole()
894+
val dataset1 = datasetApiService.createDataset(organizationSaved.id!!, dataset)
895+
val dataset2 = datasetApiService.createDataset(organizationSaved.id!!, dataset)
896+
897+
assertEquals(dataset1.connector!!.id, dataset2.connector!!.id)
898+
}
899+
891900
fun makeConnector(): Connector {
892901
return Connector(
893902
key = "connector",

dataset/src/main/kotlin/com/cosmotech/dataset/service/DatasetServiceImpl.kt

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1116,8 +1116,7 @@ class DatasetServiceImpl(
11161116
csmPlatformProperties.containers.find { it.name == TWINCACHE_CONNECTOR }
11171117
?: throw CsmResourceNotFoundException(
11181118
"Connector $TWINCACHE_CONNECTOR not found in application.yml")
1119-
val connectorName =
1120-
twinCacheConnectorProperties.name + " " + twinCacheConnectorProperties.imageVersion
1119+
val connectorName = "PlatformGenerated" + twinCacheConnectorProperties.name
11211120
try {
11221121
return connectorService.findConnectorByName(connectorName)
11231122
} catch (exception: CsmClientException) {

0 commit comments

Comments
 (0)