Skip to content

Commit 4d9169f

Browse files
authored
Make Ccs old version remote cluster setup lazy (#110106)
* Rework test cluster setup to be lazy in ccs-old-version-remote-cluster
1 parent ccf8734 commit 4d9169f

File tree

2 files changed

+15
-16
lines changed

2 files changed

+15
-16
lines changed

qa/ccs-old-version-remote-cluster/build.gradle

Lines changed: 9 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -23,30 +23,29 @@ for (Version bwcVersion : BuildParams.bwcVersions.wireCompatible) {
2323
String baseName = "v${bwcVersion}"
2424
String bwcVersionStr = "${bwcVersion}"
2525

26-
testClusters {
27-
"${baseName}-local" {
26+
def localCluster = testClusters.register("${baseName}-local") {
2827
numberOfNodes = 2
2928
versions = [project.version]
3029
setting 'cluster.remote.node.attr', 'gateway'
3130
setting 'xpack.security.enabled', 'false'
32-
}
33-
"${baseName}-remote" {
34-
numberOfNodes = 2
31+
}
32+
33+
def remoteCluster = testClusters.register("${baseName}-remote") {
34+
numberOfNodes = 2
3535
versions = [bwcVersionStr]
3636
firstNode.setting 'node.attr.gateway', 'true'
3737
lastNode.setting 'node.attr.gateway', 'true'
3838
setting 'xpack.security.enabled', 'false'
39-
}
4039
}
4140

4241
tasks.withType(StandaloneRestIntegTestTask).matching { it.name.startsWith("${baseName}#") }.configureEach {
43-
useCluster testClusters."${baseName}-local"
44-
useCluster testClusters."${baseName}-remote"
42+
useCluster localCluster
43+
useCluster remoteCluster
4544
systemProperty 'tests.upgrade_from_version', bwcVersionStr.replace('-SNAPSHOT', '')
4645

4746
doFirst {
48-
nonInputProperties.systemProperty('tests.rest.cluster', "${-> testClusters."${baseName}-local".allHttpSocketURI.join(",")}")
49-
nonInputProperties.systemProperty('tests.rest.remote_cluster', "${-> testClusters."${baseName}-remote".allHttpSocketURI.join(",")}")
47+
nonInputProperties.systemProperty('tests.rest.cluster', localCluster.map(c -> c.allHttpSocketURI.join(",")))
48+
nonInputProperties.systemProperty('tests.rest.remote_cluster', remoteCluster.map(c -> c.allHttpSocketURI.join(",")))
5049
}
5150
}
5251

qa/ccs-rolling-upgrade-remote-cluster/build.gradle

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -27,13 +27,13 @@ BuildParams.bwcVersions.withWireCompatiple { bwcVersion, baseName ->
2727
* - Only node-0 and node-2 of the remote cluster can accept remote connections. This can creates a test
2828
* scenario where a query request and fetch request are sent via **proxy nodes** that have different version.
2929
*/
30-
def localCluster = testClusters.register("${baseName}-local") {
30+
def localClusterProvider = testClusters.register("${baseName}-local") {
3131
numberOfNodes = 2
3232
versions = [bwcVersion.toString(), project.version]
3333
setting 'cluster.remote.node.attr', 'gateway'
3434
setting 'xpack.security.enabled', 'false'
3535
}
36-
def remoteCluster = testClusters.register("${baseName}-remote") {
36+
def remoteClusterProvider = testClusters.register("${baseName}-remote") {
3737
numberOfNodes = 3
3838
versions = [bwcVersion.toString(), project.version]
3939
firstNode.setting 'node.attr.gateway', 'true'
@@ -43,13 +43,13 @@ BuildParams.bwcVersions.withWireCompatiple { bwcVersion, baseName ->
4343

4444

4545
tasks.withType(StandaloneRestIntegTestTask).matching { it.name.startsWith("${baseName}#") }.configureEach {
46-
useCluster localCluster
47-
useCluster remoteCluster
46+
useCluster localClusterProvider
47+
useCluster remoteClusterProvider
4848
systemProperty 'tests.upgrade_from_version', bwcVersion.toString().replace('-SNAPSHOT', '')
4949

5050
doFirst {
51-
nonInputProperties.systemProperty('tests.rest.cluster', localCluster.map(c -> c.allHttpSocketURI.join(",")))
52-
nonInputProperties.systemProperty('tests.rest.remote_cluster', remoteCluster.map(c -> c.allHttpSocketURI.join(",")))
51+
nonInputProperties.systemProperty('tests.rest.cluster', localClusterProvider.map(c -> c.allHttpSocketURI.join(",")))
52+
nonInputProperties.systemProperty('tests.rest.remote_cluster', remoteClusterProvider.map(c -> c.allHttpSocketURI.join(",")))
5353
}
5454
}
5555

0 commit comments

Comments
 (0)