summaryrefslogtreecommitdiff
path: root/src/mongo/db/commands/pipeline_command.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/commands/pipeline_command.cpp')
-rw-r--r--src/mongo/db/commands/pipeline_command.cpp5
1 files changed, 5 insertions, 0 deletions
diff --git a/src/mongo/db/commands/pipeline_command.cpp b/src/mongo/db/commands/pipeline_command.cpp
index 90b3a2367e5..8d55c05861c 100644
--- a/src/mongo/db/commands/pipeline_command.cpp
+++ b/src/mongo/db/commands/pipeline_command.cpp
@@ -80,6 +80,11 @@ public:
!AggregationRequest::parseNs(_dbName, _request.body).isCollectionlessAggregateNS();
}
+ bool allowsSpeculativeMajorityReads() const override {
+ // TODO (SERVER-37560): Support this for change stream queries.
+ return false;
+ }
+
void run(OperationContext* opCtx, rpc::ReplyBuilderInterface* reply) override {
const auto aggregationRequest = uassertStatusOK(
AggregationRequest::parseFromBSON(_dbName, _request.body, boost::none));