From 4001c819f09e541b4d84feb74f3ad1d142cd6fc6 Mon Sep 17 00:00:00 2001 From: YamasouA Date: Wed, 5 Mar 2025 21:54:54 +0900 Subject: [PATCH] fix --- test/integration/scheduler_perf/scheduler_perf.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/test/integration/scheduler_perf/scheduler_perf.go b/test/integration/scheduler_perf/scheduler_perf.go index 9d2e2118052..cfd9830874d 100644 --- a/test/integration/scheduler_perf/scheduler_perf.go +++ b/test/integration/scheduler_perf/scheduler_perf.go @@ -1427,7 +1427,7 @@ func startCollectingMetrics(tCtx ktesting.TContext, collectorWG *sync.WaitGroup, collector := collector err := collector.init() if err != nil { - return nil, nil, fmt.Errorf("op %d: Failed to initialize data collector: %w", opIndex, err) + return nil, nil, fmt.Errorf("failed to initialize data collector: %w", err) } tCtx.TB().Cleanup(func() { collectorCtx.Cancel("cleaning up") @@ -1443,7 +1443,7 @@ func startCollectingMetrics(tCtx ktesting.TContext, collectorWG *sync.WaitGroup, func stopCollectingMetrics(tCtx ktesting.TContext, collectorCtx ktesting.TContext, collectorWG *sync.WaitGroup, threshold float64, tms thresholdMetricSelector, opIndex int, collectors []testDataCollector) ([]DataItem, error) { if collectorCtx == nil { - return nil, fmt.Errorf("op %d: Missing startCollectingMetrics operation before stopping", opIndex) + return nil, fmt.Errorf("missing startCollectingMetrics operation before stopping") } collectorCtx.Cancel("collecting metrics, collector must stop first") collectorWG.Wait()