From 5ad90c3b63a238f2e59e2634bf3c7c8d69dca996 Mon Sep 17 00:00:00 2001 From: saza-ku Date: Thu, 10 Apr 2025 19:08:25 +0900 Subject: [PATCH] merge RunBenchmarkPerfScheduling and runBenchmarkPerfScheduling --- test/integration/scheduler_perf/scheduler_perf.go | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) 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) }