Fix opIndex in log when deleting pod failed in scheduler_perf

macsko · macsko · commit 2d4d7e0b5fb5 · 2024-09-16T13:48:24.000Z
diff --git a/test/integration/scheduler_perf/scheduler_perf.go b/test/integration/scheduler_perf/scheduler_perf.go
@@ -1239,7 +1239,7 @@ func runWorkload(tCtx ktesting.TContext, tc *testCase, w *workload, informerFact
 				defer ticker.Stop()
 
 				wg.Add(1)
-				go func() {
+				go func(opIndex int) {
 					defer wg.Done()
 					for i := 0; i < len(pods); i++ {
 						select {
@@ -1254,7 +1254,7 @@ func runWorkload(tCtx ktesting.TContext, tc *testCase, w *workload, informerFact
 							return
 						}
 					}
-				}()
+				}(opIndex)
 			}
 
 		case *churnOp:

Original file line number	Diff line number	Diff line change
`@@ -1239,7 +1239,7 @@ func runWorkload(tCtx ktesting.TContext, tc testCase, w workload, informerFact`
`1239`	`1239`	`defer ticker.Stop()`
`1240`	`1240`
`1241`	`1241`	`wg.Add(1)`
`1242`		`- go func() {`
	`1242`	`+ go func(opIndex int) {`
`1243`	`1243`	`defer wg.Done()`
`1244`	`1244`	`for i := 0; i < len(pods); i++ {`
`1245`	`1245`	`select {`
`@@ -1254,7 +1254,7 @@ func runWorkload(tCtx ktesting.TContext, tc testCase, w workload, informerFact`
`1254`	`1254`	`return`
`1255`	`1255`	`}`
`1256`	`1256`	`}`
`1257`		`- }()`
	`1257`	`+ }(opIndex)`
`1258`	`1258`	`}`
`1259`	`1259`
`1260`	`1260`	`case *churnOp:`