summaryrefslogtreecommitdiff
path: root/src/mongo/db/pipeline/sharded_union_test.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/pipeline/sharded_union_test.cpp')
-rw-r--r--src/mongo/db/pipeline/sharded_union_test.cpp6
1 files changed, 3 insertions, 3 deletions
diff --git a/src/mongo/db/pipeline/sharded_union_test.cpp b/src/mongo/db/pipeline/sharded_union_test.cpp
index e9748aa0a57..395990e5309 100644
--- a/src/mongo/db/pipeline/sharded_union_test.cpp
+++ b/src/mongo/db/pipeline/sharded_union_test.cpp
@@ -205,7 +205,7 @@ TEST_F(ShardedUnionTest, CorrectlySplitsSubPipelineIfRefreshedDistributionRequir
auto shards = setupNShards(2);
const auto cm = loadRoutingTableWithTwoChunksAndTwoShards(kTestAggregateNss);
- auto&& parser = AccumulationStatement::getParser("$sum", boost::none);
+ auto&& [parser, _1, _2, _3] = AccumulationStatement::getParser("$sum");
auto accumulatorArg = BSON("" << 1);
auto sumStatement =
parser(expCtx().get(), accumulatorArg.firstElement(), expCtx()->variablesParseState);
@@ -293,7 +293,7 @@ TEST_F(ShardedUnionTest, AvoidsSplittingSubPipelineIfRefreshedDistributionDoesNo
auto shards = setupNShards(2);
const auto cm = loadRoutingTableWithTwoChunksAndTwoShards(kTestAggregateNss);
- auto&& parser = AccumulationStatement::getParser("$sum", boost::none);
+ auto&& [parser, _1, _2, _3] = AccumulationStatement::getParser("$sum");
auto accumulatorArg = BSON("" << 1);
auto sumStatement =
parser(expCtx().get(), accumulatorArg.firstElement(), expCtx()->variablesParseState);
@@ -428,7 +428,7 @@ TEST_F(ShardedUnionTest, ForwardsReadConcernToRemotes) {
setupNShards(2);
loadRoutingTableWithTwoChunksAndTwoShards(kTestAggregateNss);
- auto&& parser = AccumulationStatement::getParser("$sum", boost::none);
+ auto&& [parser, _1, _2, _3] = AccumulationStatement::getParser("$sum");
auto accumulatorArg = BSON("" << 1);
auto sumExpression =
parser(expCtx().get(), accumulatorArg.firstElement(), expCtx()->variablesParseState);