diff options
Diffstat (limited to 'src/mongo/db/pipeline/sharded_union_test.cpp')
| -rw-r--r-- | src/mongo/db/pipeline/sharded_union_test.cpp | 12 |
1 files changed, 8 insertions, 4 deletions
diff --git a/src/mongo/db/pipeline/sharded_union_test.cpp b/src/mongo/db/pipeline/sharded_union_test.cpp index 2b136a89dc2..54f4b091fa2 100644 --- a/src/mongo/db/pipeline/sharded_union_test.cpp +++ b/src/mongo/db/pipeline/sharded_union_test.cpp @@ -163,7 +163,8 @@ TEST_F(ShardedUnionTest, RetriesSubPipelineOnStaleConfigError) { Timestamp timestamp{1, 0}; return createErrorCursorResponse( Status{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"}); @@ -248,7 +249,8 @@ TEST_F(ShardedUnionTest, CorrectlySplitsSubPipelineIfRefreshedDistributionRequir Timestamp timestamp{1, 0}; return createErrorCursorResponse( Status{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"}); @@ -341,7 +343,8 @@ TEST_F(ShardedUnionTest, AvoidsSplittingSubPipelineIfRefreshedDistributionDoesNo onCommand([&](const executor::RemoteCommandRequest& request) { return createErrorCursorResponse( Status{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"}); @@ -349,7 +352,8 @@ TEST_F(ShardedUnionTest, AvoidsSplittingSubPipelineIfRefreshedDistributionDoesNo onCommand([&](const executor::RemoteCommandRequest& request) { return createErrorCursorResponse( Status{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"}); |