diff options
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.js | 7 |
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(); })(); |