1 files changed, 6 insertions, 2 deletions
diff --git a/src/mongo/s/commands/cluster_pipeline_cmd_s.cpp b/src/mongo/s/commands/cluster_pipeline_cmd_s.cpp
index 3009d9265e6..d099095fe96 100644
--- a/src/mongo/s/commands/cluster_pipeline_cmd_s.cpp
+++ b/src/mongo/s/commands/cluster_pipeline_cmd_s.cpp
@@ -54,11 +54,15 @@ struct ClusterPipelineCommandS {
     }
 
     static AggregateCommandRequest parseAggregationRequest(
+        OperationContext* opCtx,
         const OpMsgRequest& opMsgRequest,
         boost::optional<ExplainOptions::Verbosity> explainVerbosity,
         bool apiStrict) {
-        return aggregation_request_helper::parseFromBSON(
-            opMsgRequest.getDatabase().toString(), opMsgRequest.body, explainVerbosity, apiStrict);
+        return aggregation_request_helper::parseFromBSON(opCtx,
+                                                         opMsgRequest.getDatabase().toString(),
+                                                         opMsgRequest.body,
+                                                         explainVerbosity,
+                                                         apiStrict);
     }
 };
 ClusterPipelineCommandBase<ClusterPipelineCommandS> clusterPipelineCmdS;