diff options
Diffstat (limited to 'src/mongo/s/commands/cluster_pipeline_cmd.cpp')
-rw-r--r-- | src/mongo/s/commands/cluster_pipeline_cmd.cpp | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/src/mongo/s/commands/cluster_pipeline_cmd.cpp b/src/mongo/s/commands/cluster_pipeline_cmd.cpp index f3b4fa36e71..b09d02b522f 100644 --- a/src/mongo/s/commands/cluster_pipeline_cmd.cpp +++ b/src/mongo/s/commands/cluster_pipeline_cmd.cpp @@ -35,6 +35,7 @@ #include "mongo/base/status.h" #include "mongo/db/auth/authorization_session.h" #include "mongo/db/commands.h" +#include "mongo/db/pipeline/lite_parsed_pipeline.h" #include "mongo/s/commands/cluster_aggregate.h" namespace mongo { @@ -106,8 +107,13 @@ private: const auto& nss = aggregationRequest.getNamespaceString(); - return ClusterAggregate::runAggregate( + auto status = ClusterAggregate::runAggregate( opCtx, ClusterAggregate::Namespaces{nss, nss}, aggregationRequest, cmdObj, result); + if (status.isOK()) { + LiteParsedPipeline lpp(aggregationRequest); + lpp.tickGlobalStageCounters(); + } + return status; } } clusterPipelineCmd; |