@@ -429,7 +429,7 @@ class ClusterFormationTasks {
429429
430430 Project pluginProject = plugin. getValue()
431431 verifyProjectHasBuildPlugin(name, node. nodeVersion, project, pluginProject)
432- String configurationName = " _plugin_ ${ prefix} _ ${ pluginProject.path } "
432+ String configurationName = pluginConfigurationName( prefix, pluginProject)
433433 Configuration configuration = project. configurations. findByName(configurationName)
434434 if (configuration == null ) {
435435 configuration = project. configurations. create(configurationName)
@@ -458,13 +458,21 @@ class ClusterFormationTasks {
458458 return copyPlugins
459459 }
460460
461+ private static String pluginConfigurationName (final String prefix , final Project project ) {
462+ return " _plugin_${ prefix} _${ project.path} " . replace(' :' , ' _' )
463+ }
464+
465+ private static String pluginBwcConfigurationName (final String prefix , final Project project ) {
466+ return " _plugin_bwc_${ prefix} _${ project.path} " . replace(' :' , ' _' )
467+ }
468+
461469 /* * Configures task to copy a plugin based on a zip file resolved using dependencies for an older version */
462470 static Task configureCopyBwcPluginsTask (String name , Project project , Task setup , NodeInfo node , String prefix ) {
463471 Configuration bwcPlugins = project. configurations. getByName(" ${ prefix} _elasticsearchBwcPlugins" )
464472 for (Map.Entry < String , Project > plugin : node. config. plugins. entrySet()) {
465473 Project pluginProject = plugin. getValue()
466474 verifyProjectHasBuildPlugin(name, node. nodeVersion, project, pluginProject)
467- String configurationName = " _plugin_bwc_ ${ prefix} _ ${ pluginProject.path } "
475+ String configurationName = pluginBwcConfigurationName( prefix, pluginProject)
468476 Configuration configuration = project. configurations. findByName(configurationName)
469477 if (configuration == null ) {
470478 configuration = project. configurations. create(configurationName)
@@ -503,9 +511,9 @@ class ClusterFormationTasks {
503511 static Task configureInstallPluginTask (String name , Project project , Task setup , NodeInfo node , Project plugin , String prefix ) {
504512 final FileCollection pluginZip;
505513 if (node. nodeVersion != VersionProperties . elasticsearch) {
506- pluginZip = project. configurations. getByName(" _plugin_bwc_ ${ prefix} _ ${ plugin.path } " )
514+ pluginZip = project. configurations. getByName(pluginBwcConfigurationName( prefix, plugin) )
507515 } else {
508- pluginZip = project. configurations. getByName(" _plugin_ ${ prefix} _ ${ plugin.path } " )
516+ pluginZip = project. configurations. getByName(pluginConfigurationName( prefix, plugin) )
509517 }
510518 // delay reading the file location until execution time by wrapping in a closure within a GString
511519 final Object file = " ${ -> new File(node.pluginsTmpDir, pluginZip.singleFile.getName()).toURI().toURL().toString()} "
0 commit comments