summaryrefslogtreecommitdiff
path: root/src/mongo/s/commands/cluster_pipeline_cmd.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/s/commands/cluster_pipeline_cmd.cpp')
-rw-r--r--src/mongo/s/commands/cluster_pipeline_cmd.cpp8
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;