From 96f07ca60e92b4b2c5722b70c74bd850b82ed439 Mon Sep 17 00:00:00 2001 From: svijaykumar-px Date: Thu, 22 Aug 2024 08:25:21 +0000 Subject: [PATCH] Counting only storage nodes for pdb validation --- tests/common.go | 12 ++---------- 1 file changed, 2 insertions(+), 10 deletions(-) diff --git a/tests/common.go b/tests/common.go index aae585bb3..1e9a44b0f 100644 --- a/tests/common.go +++ b/tests/common.go @@ -12813,11 +12813,7 @@ func SwitchBothKubeConfigANDContext(cluster string) error { func DoPDBValidation(stopSignal <-chan struct{}, mError *error) { pdbValue, allowedDisruptions := GetPDBValue() isClusterParallelyUpgraded := false - nodes, err := Inst().V.GetDriverNodes() - if err != nil { - *mError = multierr.Append(*mError, err) - return - } + nodes := node.GetStorageNodes() totalNodes := len(nodes) itr := 1 for { @@ -14329,11 +14325,7 @@ func DoVolumeQuorumValidation(volumeQuorumValidationStopSignal chan struct{}, vQ } func DoParallelUpgradePDBValidation(stopSignal <-chan struct{}, mError *error) { - nodes, err := Inst().V.GetDriverNodes() - if err != nil { - *mError = multierr.Append(*mError, err) - return - } + nodes := node.GetStorageNodes() stc, err := Inst().V.GetDriver() if err != nil { *mError = multierr.Append(*mError, err)