@@ -2283,26 +2283,28 @@ def launchTestJobs(pipeline, testFilter, dockerNode=null)
2283
2283
pipeline. echo " Now we will run stages: [\n ${ keysStr} \n ]"
2284
2284
2285
2285
parallelJobsFiltered = parallelJobsFiltered. collectEntries { key , values -> [key, {
2286
- trtllm_utils. llmStageWithRetry(pipeline, key, {
2287
- if (key in testFilter[REUSE_STAGE_LIST ]) {
2288
- stage(" Skip - reused" ) {
2289
- echo " Skip - Passed in the last pipeline."
2290
- }
2291
- } else if (values instanceof List && dockerNode == null ) {
2292
- trtllm_utils. launchKubernetesPod(pipeline, values[0 ], " trt-llm" , {
2293
- values[1 ]()
2294
- })
2295
- } else if (values instanceof List && dockerNode != null ) {
2296
- node(dockerNode) {
2297
- deleteDir()
2298
- docker. image(LLM_DOCKER_IMAGE ). inside(dockerArgs) {
2286
+ stage(key) {
2287
+ trtllm_utils. llmStageWithRetry(pipeline, key, {
2288
+ if (key in testFilter[REUSE_STAGE_LIST ]) {
2289
+ stage(" Skip - reused" ) {
2290
+ echo " Skip - Passed in the last pipeline."
2291
+ }
2292
+ } else if (values instanceof List && dockerNode == null ) {
2293
+ trtllm_utils. launchKubernetesPod(pipeline, values[0 ], " trt-llm" , {
2299
2294
values[1 ]()
2295
+ })
2296
+ } else if (values instanceof List && dockerNode != null ) {
2297
+ node(dockerNode) {
2298
+ deleteDir()
2299
+ docker. image(LLM_DOCKER_IMAGE ). inside(dockerArgs) {
2300
+ values[1 ]()
2301
+ }
2300
2302
}
2303
+ } else {
2304
+ values()
2301
2305
}
2302
- } else {
2303
- values()
2304
- }
2305
- })
2306
+ })
2307
+ }
2306
2308
}]}
2307
2309
2308
2310
return parallelJobsFiltered
0 commit comments