Skip to content

Commit 27a2df6

Browse files
committed
fix generated connector name to simplify redis search
Redis search have a hard time with dot(.)
1 parent 985180b commit 27a2df6

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
@@ -1126,8 +1126,7 @@ class DatasetServiceImpl(
11261126
csmPlatformProperties.containers.find { it.name == TWINCACHE_CONNECTOR }
11271127
?: throw CsmResourceNotFoundException(
11281128
"Connector $TWINCACHE_CONNECTOR not found in application.yml")
1129-
val connectorName =
1130-
twinCacheConnectorProperties.name + " " + twinCacheConnectorProperties.imageVersion
1129+
val connectorName = "PlatformGenerated" + twinCacheConnectorProperties.name
11311130
try {
11321131
return connectorService.findConnectorByName(connectorName)
11331132
} catch (exception: CsmClientException) {

0 commit comments

Comments
 (0)