?: return None

            return when (methodJsonNode.get("name")?.asText()) {
                null -> None
                None::class.simpleName -> None
                TestDistribution::class.simpleName -> TestDistribution
                TestDistributionAlpine::class.simpleName -> TestDistributionAlpine
                TeamCityParallelTests::class.simpleName ->
                    TeamCityParallelTests(

        // The distribution can be configured with -Dtests.distribution on the command line
        project.testClusters.matching { it.name.equals("integTest") }.configureEach { testDistribution = distribution.toUpperCase() }
        project.testClusters.matching { it.name.equals("integTest") }.configureEach { nameCustomization = { it.replace("integTest", "node") } }

// precompiled script plugins (see https://github.com/gradle/gradle/issues/17004)
// apply plugin: 'elasticsearch.internal-testclusters'

testClusters.register("runTask") {
    testDistribution = providers.systemProperty('run.distribution').orElse('default').forUseAtConfigurationTime().get()
    if (providers.systemProperty('run.distribution').orElse('default').forUseAtConfigurationTime().get() == 'default') {

 * Side Public License, v 1.
 */

import org.elasticsearch.gradle.internal.ExportElasticsearchBuildResourcesTask
import org.elasticsearch.gradle.internal.info.BuildParams
import org.elasticsearch.gradle.testclusters.TestDistribution
import org.elasticsearch.gradle.testclusters.TestClustersAware

// Common config when running with a FIPS-140 runtime JVM
if (BuildParams.inFipsJvm) {

  allprojects {

        name = "${docsTestType.docsTestDesc} - ${testJava.version.toCapitalized()} ${os.asName()}"
        val parallelizationMethod =
            if (os == Os.LINUX) {
                ParallelizationMethod.TestDistribution
            } else {
                TeamCityParallelTests(4)
            }

        if (parallelizationMethod is TeamCityParallelTests) {
            features {
                parallelTests {

        return parallelize(subProjectTestClassTimes, testCoverage) { numberOfBatches ->
            when (testCoverage.os) {
                Os.LINUX -> ParallelizationMethod.TestDistribution
                Os.ALPINE -> ParallelizationMethod.TestDistributionAlpine
                else -> ParallelizationMethod.TeamCityParallelTests(numberOfBatches)
            }
        }
    }

        testCoverage: TestCoverage,
        bucketIndex: Int,
    ): FunctionalTest {
        val parallelizationMethod =
            when (testCoverage.os) {
                Os.LINUX -> ParallelizationMethod.TestDistribution
                else -> ParallelizationMethod.None
            }

        return FunctionalTest(
            model,
            testCoverage.getBucketUuid(model, bucketIndex),