SERVER-66720 Interrupt migration-related commands on CSRS upon stepdown

1 files changed, 3 insertions, 3 deletions

diff --git a/src/mongo/db/s/balancer/balancer.cpp b/src/mongo/db/s/balancer/balancer.cpp
index 302fb24b3d7..d241dee3936 100644
--- a/src/mongo/db/s/balancer/balancer.cpp
+++ b/src/mongo/db/s/balancer/balancer.cpp
@@ -356,7 +356,7 @@ Status Balancer::rebalanceSingleChunk(OperationContext* opCtx,
     auto response =
         _commandScheduler
             ->requestMoveChunk(opCtx, *migrateInfo, settings, true /* issuedByRemoteUser */)
-            .getNoThrow();
+            .getNoThrow(opCtx);
     return processManualMigrationOutcome(opCtx, chunk.getMin(), nss, migrateInfo->to, response);
 }
 
@@ -385,7 +385,7 @@ Status Balancer::moveSingleChunk(OperationContext* opCtx,
     auto response =
         _commandScheduler
             ->requestMoveChunk(opCtx, migrateInfo, settings, true /* issuedByRemoteUser */)
-            .getNoThrow();
+            .getNoThrow(opCtx);
     return processManualMigrationOutcome(opCtx, chunk.getMin(), nss, newShardId, response);
 }
 
@@ -418,7 +418,7 @@ Status Balancer::moveRange(OperationContext* opCtx,
 
     auto response =
         _commandScheduler->requestMoveRange(opCtx, shardSvrRequest, wc, issuedByRemoteUser)
-            .getNoThrow();
+            .getNoThrow(opCtx);
     return processManualMigrationOutcome(
         opCtx, min, nss, shardSvrRequest.getToShard(), std::move(response));
 }