diff --git a/test/integration/scheduler_perf/scheduler_perf.go b/test/integration/scheduler_perf/scheduler_perf.go index b6b8c030d38..511d08ac4bf 100644 --- a/test/integration/scheduler_perf/scheduler_perf.go +++ b/test/integration/scheduler_perf/scheduler_perf.go @@ -1156,10 +1156,6 @@ func RunBenchmarkPerfScheduling(b *testing.B, configFile string, topicName strin option(opts) } - runBenchmarkPerSchedulingImpl(b, configFile, topicName, outOfTreePluginRegistry, opts) -} - -func runBenchmarkPerSchedulingImpl(b *testing.B, configFile string, topicName string, outOfTreePluginRegistry frameworkruntime.Registry, options *schedulerPerfOptions) { testCases, err := getTestCases(configFile) if err != nil { b.Fatal(err) @@ -1206,8 +1202,8 @@ func runBenchmarkPerSchedulingImpl(b *testing.B, configFile string, topicName st b.Fatalf("workload %s is not valid: %v", w.Name, err) } - if options.prepareFn != nil { - err = options.prepareFn(tCtx) + if opts.prepareFn != nil { + err = opts.prepareFn(tCtx) if err != nil { b.Fatalf("failed to run prepareFn: %v", err) }