@@ -425,7 +425,7 @@ class ClusterFormationTasks {
425
425
426
426
Project pluginProject = plugin. getValue()
427
427
verifyProjectHasBuildPlugin(name, node. nodeVersion, project, pluginProject)
428
- String configurationName = " _plugin_ ${ prefix} _ ${ pluginProject.path } "
428
+ String configurationName = pluginConfigurationName( prefix, pluginProject)
429
429
Configuration configuration = project. configurations. findByName(configurationName)
430
430
if (configuration == null ) {
431
431
configuration = project. configurations. create(configurationName)
@@ -454,13 +454,21 @@ class ClusterFormationTasks {
454
454
return copyPlugins
455
455
}
456
456
457
+ private static String pluginConfigurationName (final String prefix , final Project project ) {
458
+ return " _plugin_${ prefix} _${ project.path} " . replace(' :' , ' _' )
459
+ }
460
+
461
+ private static String pluginBwcConfigurationName (final String prefix , final Project project ) {
462
+ return " _plugin_bwc_${ prefix} _${ project.path} " . replace(' :' , ' _' )
463
+ }
464
+
457
465
/* * Configures task to copy a plugin based on a zip file resolved using dependencies for an older version */
458
466
static Task configureCopyBwcPluginsTask (String name , Project project , Task setup , NodeInfo node , String prefix ) {
459
467
Configuration bwcPlugins = project. configurations. getByName(" ${ prefix} _elasticsearchBwcPlugins" )
460
468
for (Map.Entry < String , Project > plugin : node. config. plugins. entrySet()) {
461
469
Project pluginProject = plugin. getValue()
462
470
verifyProjectHasBuildPlugin(name, node. nodeVersion, project, pluginProject)
463
- String configurationName = " _plugin_bwc_ ${ prefix} _ ${ pluginProject.path } "
471
+ String configurationName = pluginBwcConfigurationName( prefix, pluginProject)
464
472
Configuration configuration = project. configurations. findByName(configurationName)
465
473
if (configuration == null ) {
466
474
configuration = project. configurations. create(configurationName)
@@ -499,9 +507,9 @@ class ClusterFormationTasks {
499
507
static Task configureInstallPluginTask (String name , Project project , Task setup , NodeInfo node , Project plugin , String prefix ) {
500
508
final FileCollection pluginZip;
501
509
if (node. nodeVersion != VersionProperties . elasticsearch) {
502
- pluginZip = project. configurations. getByName(" _plugin_bwc_ ${ prefix} _ ${ plugin.path } " )
510
+ pluginZip = project. configurations. getByName(pluginBwcConfigurationName( prefix, plugin) )
503
511
} else {
504
- pluginZip = project. configurations. getByName(" _plugin_ ${ prefix} _ ${ plugin.path } " )
512
+ pluginZip = project. configurations. getByName(pluginConfigurationName( prefix, plugin) )
505
513
}
506
514
// delay reading the file location until execution time by wrapping in a closure within a GString
507
515
final Object file = " ${ -> new File(node.pluginsTmpDir, pluginZip.singleFile.getName()).toURI().toURL().toString()} "
0 commit comments