github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-31 15:25:57 +00:00
Code Issues Projects Releases Wiki Activity

tweak

Browse Source
This commit is contained in:
YamasouA 2025-03-05 12:59:17 +09:00
parent 8e4b00e949
commit 32fd0de21c
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
test/integration/scheduler_perf/scheduler_perf.go
View File

@ -1672,7 +1672,7 @@ func (e *WorkloadExecutor) runCreatePodsOp(opIndex int, op *createPodsOp) error
if op.CollectMetrics { if op.CollectMetrics {
if e.collectorCtx != nil { if e.collectorCtx != nil {
return fmt.Errorf("Metrics collection is overlapping. Probably second collector was started before stopping a previous one") return fmt.Errorf("metrics collection is overlapping. Probably second collector was started before stopping a previous one")
} }
var err error var err error
e.collectorCtx, e.collectors, err = startCollectingMetrics(e.tCtx, &e.collectorWG, e.podInformer, e.testCase.MetricsCollectorConfig, e.throughputErrorMargin, opIndex, namespace, []string{namespace}, nil) e.collectorCtx, e.collectors, err = startCollectingMetrics(e.tCtx, &e.collectorWG, e.podInformer, e.testCase.MetricsCollectorConfig, e.throughputErrorMargin, opIndex, namespace, []string{namespace}, nil)
@ -1886,7 +1886,7 @@ func (e *WorkloadExecutor) runDefaultOp(opIndex int, op realOp) error {
func (e *WorkloadExecutor) runStartCollectingMetricsOp(opIndex int, op *startCollectingMetricsOp) error { func (e *WorkloadExecutor) runStartCollectingMetricsOp(opIndex int, op *startCollectingMetricsOp) error {
if e.collectorCtx != nil { if e.collectorCtx != nil {
return fmt.Errorf("Metrics collection is overlapping. Probably second collector was started before stopping a previous one") return fmt.Errorf("metrics collection is overlapping. Probably second collector was started before stopping a previous one")
} }
var err error var err error
e.collectorCtx, e.collectors, err = startCollectingMetrics(e.tCtx, &e.collectorWG, e.podInformer, e.testCase.MetricsCollectorConfig, e.throughputErrorMargin, opIndex, op.Name, op.Namespaces, op.LabelSelector) e.collectorCtx, e.collectors, err = startCollectingMetrics(e.tCtx, &e.collectorWG, e.podInformer, e.testCase.MetricsCollectorConfig, e.throughputErrorMargin, opIndex, op.Name, op.Namespaces, op.LabelSelector)