summaryrefslogtreecommitdiff
path: root/src/mongo/db/pipeline/dispatch_shard_pipeline_test.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/pipeline/dispatch_shard_pipeline_test.cpp')
-rw-r--r--src/mongo/db/pipeline/dispatch_shard_pipeline_test.cpp6
1 files changed, 4 insertions, 2 deletions
diff --git a/src/mongo/db/pipeline/dispatch_shard_pipeline_test.cpp b/src/mongo/db/pipeline/dispatch_shard_pipeline_test.cpp
index 26eb3002a80..79b666c1956 100644
--- a/src/mongo/db/pipeline/dispatch_shard_pipeline_test.cpp
+++ b/src/mongo/db/pipeline/dispatch_shard_pipeline_test.cpp
@@ -176,7 +176,8 @@ TEST_F(DispatchShardPipelineTest, DispatchShardPipelineDoesNotRetryOnStaleConfig
Timestamp timestamp{1, 0};
return createErrorCursorResponse(
{StaleConfigInfo(kTestAggregateNss,
- ShardVersion(ChunkVersion({epoch, timestamp}, {1, 0})),
+ ShardVersion(ChunkVersion({epoch, timestamp}, {1, 0}),
+ CollectionIndexes({epoch, timestamp}, boost::none)),
boost::none,
ShardId{"0"}),
"Mock error: shard version mismatch"});
@@ -220,7 +221,8 @@ TEST_F(DispatchShardPipelineTest, WrappedDispatchDoesRetryOnStaleConfigError) {
onCommand([&](const executor::RemoteCommandRequest& request) {
return createErrorCursorResponse(
{StaleConfigInfo(kTestAggregateNss,
- ShardVersion(ChunkVersion({epoch, timestamp}, {2, 0})),
+ ShardVersion(ChunkVersion({epoch, timestamp}, {2, 0}),
+ CollectionIndexes({epoch, timestamp}, boost::none)),
boost::none,
ShardId{"0"}),
"Mock error: shard version mismatch"});