summaryrefslogtreecommitdiff
path: root/jstests/replsets/tenant_migration_recipient_invalidates_in_memory_txns.js
diff options
context:
space:
mode:
Diffstat (limited to 'jstests/replsets/tenant_migration_recipient_invalidates_in_memory_txns.js')
-rw-r--r--jstests/replsets/tenant_migration_recipient_invalidates_in_memory_txns.js7
1 files changed, 3 insertions, 4 deletions
diff --git a/jstests/replsets/tenant_migration_recipient_invalidates_in_memory_txns.js b/jstests/replsets/tenant_migration_recipient_invalidates_in_memory_txns.js
index e916e36b7d3..d5b22b9ec26 100644
--- a/jstests/replsets/tenant_migration_recipient_invalidates_in_memory_txns.js
+++ b/jstests/replsets/tenant_migration_recipient_invalidates_in_memory_txns.js
@@ -77,8 +77,7 @@ const migrationOpts1 = {
migrationIdString: extractUUIDFromObject(migrationId1),
tenantId,
};
-let migrationRes = assert.commandWorked(tenantMigrationTest.runMigration(migrationOpts1));
-assert.eq(migrationRes.state, TenantMigrationTest.State.kCommitted);
+TenantMigrationTest.assertCommitted(tenantMigrationTest.runMigration(migrationOpts1));
tenantMigrationTest.waitForMigrationGarbageCollection(migrationId1, tenantId);
// Verify that the config.transaction entry was migrated successfully.
@@ -107,10 +106,10 @@ const migrationOpts2 = {
migrationIdString: extractUUIDFromObject(migrationId2),
tenantId,
};
-migrationRes = assert.commandWorked(tenantMigrationTest.runMigration(migrationOpts2));
+
// The migration should have committed successfully even though the in-memory transaction number was
// higher, since the higher number should have been invalidated.
-assert.eq(migrationRes.state, TenantMigrationTest.State.kCommitted);
+TenantMigrationTest.assertCommitted(tenantMigrationTest.runMigration(migrationOpts2));
tenantMigrationTest.stop();
})();