summaryrefslogtreecommitdiff
path: root/src/mongo/db/commands/run_aggregate.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/commands/run_aggregate.cpp')
-rw-r--r--src/mongo/db/commands/run_aggregate.cpp5
1 files changed, 3 insertions, 2 deletions
diff --git a/src/mongo/db/commands/run_aggregate.cpp b/src/mongo/db/commands/run_aggregate.cpp
index 6b915fc5329..bf6b65c13f4 100644
--- a/src/mongo/db/commands/run_aggregate.cpp
+++ b/src/mongo/db/commands/run_aggregate.cpp
@@ -402,8 +402,9 @@ void _adjustChangeStreamReadConcern(OperationContext* opCtx) {
}
// Wait for read concern again since we changed the original read concern.
- uassertStatusOK(waitForReadConcern(
- opCtx, readConcernArgs, true, PrepareConflictBehavior::kIgnoreConflicts));
+ uassertStatusOK(waitForReadConcern(opCtx, readConcernArgs, true));
+ setPrepareConflictBehaviorForReadConcern(
+ opCtx, readConcernArgs, PrepareConflictBehavior::kIgnoreConflicts);
}
/**