diff options
Diffstat (limited to 'src/mongo/s/commands/cluster_distinct_cmd.cpp')
| -rw-r--r-- | src/mongo/s/commands/cluster_distinct_cmd.cpp | 9 |
1 files changed, 3 insertions, 6 deletions
diff --git a/src/mongo/s/commands/cluster_distinct_cmd.cpp b/src/mongo/s/commands/cluster_distinct_cmd.cpp index 7d1e5bc7c0b..7e695d526e2 100644 --- a/src/mongo/s/commands/cluster_distinct_cmd.cpp +++ b/src/mongo/s/commands/cluster_distinct_cmd.cpp @@ -138,15 +138,13 @@ public: viewAggCmd, verbosity, APIParameters::get(opCtx).getAPIStrict().value_or(false)); - if (!aggRequestOnView.isOK()) { - return aggRequestOnView.getStatus(); - } + auto bodyBuilder = result->getBodyBuilder(); // An empty PrivilegeVector is acceptable because these privileges are only checked on // getMore and explain will not open a cursor. return ClusterAggregate::retryOnViewError(opCtx, - aggRequestOnView.getValue(), + aggRequestOnView, *ex.extraInfo<ResolvedView>(), nss, PrivilegeVector(), @@ -216,9 +214,8 @@ public: viewAggCmd, boost::none, APIParameters::get(opCtx).getAPIStrict().value_or(false)); - uassertStatusOK(aggRequestOnView.getStatus()); - auto resolvedAggRequest = ex->asExpandedViewAggregation(aggRequestOnView.getValue()); + auto resolvedAggRequest = ex->asExpandedViewAggregation(aggRequestOnView); auto resolvedAggCmd = aggregation_request_helper::serializeToCommandObj(resolvedAggRequest); |