1 files changed, 3 insertions, 1 deletions
diff --git a/src/mongo/db/s/cluster_pipeline_cmd_d.cpp b/src/mongo/db/s/cluster_pipeline_cmd_d.cpp
index cd78fa52e18..8526a411f67 100644
--- a/src/mongo/db/s/cluster_pipeline_cmd_d.cpp
+++ b/src/mongo/db/s/cluster_pipeline_cmd_d.cpp
@@ -62,13 +62,15 @@ struct ClusterPipelineCommandD {
     }
 
     static AggregateCommandRequest parseAggregationRequest(
+        OperationContext* opCtx,
         const OpMsgRequest& opMsgRequest,
         boost::optional<ExplainOptions::Verbosity> explainVerbosity,
         bool apiStrict) {
         // Replace clusterAggregate in the request body because the parser doesn't recognize it.
         auto modifiedRequestBody =
             opMsgRequest.body.replaceFieldNames(BSON(AggregateCommandRequest::kCommandName << 1));
-        return aggregation_request_helper::parseFromBSON(opMsgRequest.getDatabase().toString(),
+        return aggregation_request_helper::parseFromBSON(opCtx,
+                                                         opMsgRequest.getDatabase().toString(),
                                                          modifiedRequestBody,
                                                          explainVerbosity,
                                                          apiStrict);