Skip to content

Commit

Permalink
fix test as versions are different due to unified ckpt
Browse files Browse the repository at this point in the history
  • Loading branch information
badrishc committed Mar 8, 2025
1 parent 7b7bec5 commit bbad4f0
Showing 1 changed file with 8 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -236,7 +236,9 @@ public void ClusterDBVersionAlignmentDisklessSync([Values] bool disableObjects,
// Validate db version
var primaryVersion = context.clusterTestUtils.GetStoreCurrentVersion(primaryIndex, isMainStore: true, logger: context.logger);
var replicaOneVersion = context.clusterTestUtils.GetStoreCurrentVersion(replicaOneIndex, isMainStore: true, logger: context.logger);
ClassicAssert.AreEqual(2, primaryVersion);

var expectedVersion1 = disableObjects ? 2 : 3;
ClassicAssert.AreEqual(expectedVersion1, primaryVersion);
ClassicAssert.AreEqual(primaryVersion, replicaOneVersion);

// Reset and re-attach replica as primary
Expand All @@ -258,9 +260,10 @@ public void ClusterDBVersionAlignmentDisklessSync([Values] bool disableObjects,
primaryVersion = context.clusterTestUtils.GetStoreCurrentVersion(primaryIndex, isMainStore: true, logger: context.logger);
replicaOneVersion = context.clusterTestUtils.GetStoreCurrentVersion(replicaOneIndex, isMainStore: true, logger: context.logger);
var replicaTwoVersion = context.clusterTestUtils.GetStoreCurrentVersion(replicaTwoIndex, isMainStore: true, logger: context.logger);
ClassicAssert.AreEqual(3, primaryVersion);
var expectedVersion2 = disableObjects ? 3 : 5;
ClassicAssert.AreEqual(expectedVersion2, primaryVersion);
ClassicAssert.AreEqual(primaryVersion, replicaTwoVersion);
ClassicAssert.AreEqual(2, replicaOneVersion);
ClassicAssert.AreEqual(expectedVersion1, replicaOneVersion);

// Re-attach first replica
_ = context.clusterTestUtils.ClusterReplicate(replicaNodeIndex: replicaOneIndex, primaryNodeIndex: primaryIndex, logger: context.logger);
Expand All @@ -271,7 +274,8 @@ public void ClusterDBVersionAlignmentDisklessSync([Values] bool disableObjects,
primaryVersion = context.clusterTestUtils.GetStoreCurrentVersion(primaryIndex, isMainStore: true, logger: context.logger);
replicaOneVersion = context.clusterTestUtils.GetStoreCurrentVersion(replicaOneIndex, isMainStore: true, logger: context.logger);
replicaTwoVersion = context.clusterTestUtils.GetStoreCurrentVersion(replicaTwoIndex, isMainStore: true, logger: context.logger);
ClassicAssert.AreEqual(4, primaryVersion);
var expectedVersion3 = disableObjects ? 4 : 7;
ClassicAssert.AreEqual(expectedVersion3, primaryVersion);
ClassicAssert.AreEqual(primaryVersion, replicaOneVersion);
ClassicAssert.AreEqual(primaryVersion, replicaTwoVersion);
}
Expand Down

0 comments on commit bbad4f0

Please sign in to comment.