1 files changed, 6 insertions, 3 deletions
diff --git a/jstests/replsets/tenant_migration_fetch_committed_transactions_retry.js b/jstests/replsets/tenant_migration_fetch_committed_transactions_retry.js
index 1606d0a4ec6..bc20a96f090 100644
--- a/jstests/replsets/tenant_migration_fetch_committed_transactions_retry.js
+++ b/jstests/replsets/tenant_migration_fetch_committed_transactions_retry.js
@@ -115,7 +115,8 @@ const assertTransactionEntries = (donorTxnEntries, recipientTxnEntries) => {
     fpAfterCollectionClonerDone.off();
 
     // Verify that the migration completes successfully.
-    assert.commandWorked(tenantMigrationTest.waitForMigrationToComplete(migrationOpts));
+    TenantMigrationTest.assertCommitted(
+        tenantMigrationTest.waitForMigrationToComplete(migrationOpts));
     recipientTxnEntries = recipientPrimary.getCollection(transactionsNS).find().toArray();
     assertTransactionEntries(donorTxnEntries, recipientTxnEntries);
 
@@ -180,7 +181,8 @@ const assertTransactionEntries = (donorTxnEntries, recipientTxnEntries) => {
     fpAfterCollectionClonerDone.off();
 
     // Verify that the migration completes successfully.
-    assert.commandWorked(tenantMigrationTest.waitForMigrationToComplete(migrationOpts));
+    TenantMigrationTest.assertCommitted(
+        tenantMigrationTest.waitForMigrationToComplete(migrationOpts));
 
     recipientTxnEntries = recipientPrimary.getCollection(transactionsNS).find().toArray();
     assertTransactionEntries(donorTxnEntries, recipientTxnEntries);
@@ -256,7 +258,8 @@ const assertTransactionEntries = (donorTxnEntries, recipientTxnEntries) => {
     fpAfterCollectionClonerDone.off();
 
     // Verify that the migration completes successfully.
-    assert.commandWorked(tenantMigrationTest.waitForMigrationToComplete(migrationOpts));
+    TenantMigrationTest.assertCommitted(
+        tenantMigrationTest.waitForMigrationToComplete(migrationOpts));
 
     recipientTxnEntries = recipientPrimary.getCollection(transactionsNS).find().toArray();
     assertTransactionEntries(updatedDonorTxnEntries, recipientTxnEntries);