|
70 | 70 | testFocus = flag.String("test-focus", "", "test focus for Kubernetes e2e")
|
71 | 71 |
|
72 | 72 | useKubeTest2 = flag.Bool("use-kubetest2", false, "use kubetest2 to run e2e tests")
|
| 73 | + parallel = flag.Int("parallel", 10, "the number of parallel tests setting for ginkgo parallelism") |
73 | 74 | )
|
74 | 75 |
|
75 | 76 | const (
|
@@ -99,6 +100,7 @@ type testParameters struct {
|
99 | 100 | clusterVersion string
|
100 | 101 | nodeVersion string
|
101 | 102 | imageType string
|
| 103 | + parallel int |
102 | 104 | }
|
103 | 105 |
|
104 | 106 | func init() {
|
@@ -200,6 +202,7 @@ func handle() error {
|
200 | 202 | deploymentStrategy: *deploymentStrat,
|
201 | 203 | useGKEManagedDriver: *useGKEManagedDriver,
|
202 | 204 | imageType: *imageType,
|
| 205 | + parallel: *parallel, |
203 | 206 | }
|
204 | 207 |
|
205 | 208 | goPath, ok := os.LookupEnv("GOPATH")
|
@@ -663,8 +666,7 @@ func runTestsWithConfig(testParams *testParameters, testConfigArg, reportPrefix
|
663 | 666 | }
|
664 | 667 | kubeTest2Args = append(kubeTest2Args, fmt.Sprintf("--focus-regex=%s", testParams.testFocus))
|
665 | 668 | kubeTest2Args = append(kubeTest2Args, fmt.Sprintf("--skip-regex=%s", testParams.testSkip))
|
666 |
| - // kubetest uses 25 as default value for ginkgo parallelism (--nodes). |
667 |
| - kubeTest2Args = append(kubeTest2Args, "--parallel=25") |
| 669 | + kubeTest2Args = append(kubeTest2Args, fmt.Sprintf("--parallel=%d", testParams.parallel)) |
668 | 670 | kubeTest2Args = append(kubeTest2Args, fmt.Sprintf("--test-args=%s %s", testConfigArg, windowsArgs))
|
669 | 671 |
|
670 | 672 | if kubetestDumpDir != "" {
|
|
0 commit comments