diff options
| author | Rishab Joshi <rishab.joshi@mongodb.com> | 2021-04-29 12:49:04 +0000 |
|---|---|---|
| committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2021-04-30 00:42:46 +0000 |
| commit | 8e30a28df2f10b53ee83f034f26b805c5e980914 (patch) | |
| tree | fd57ca827372e5c317efec00a1a838bbb3f00abe /src/mongo/db/pipeline/sharded_agg_helpers.cpp | |
| parent | e5e1ac3798b786d179ec16d4deec3744c5dc3be7 (diff) | |
| download | mongo-8e30a28df2f10b53ee83f034f26b805c5e980914.tar.gz | |
SERVER-54937 Removes DocumentSourceChangeStreamCloseCursor dependencies on invalidate events
Diffstat (limited to 'src/mongo/db/pipeline/sharded_agg_helpers.cpp')
| -rw-r--r-- | src/mongo/db/pipeline/sharded_agg_helpers.cpp | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/src/mongo/db/pipeline/sharded_agg_helpers.cpp b/src/mongo/db/pipeline/sharded_agg_helpers.cpp index 678d5b24caf..9fe9104da25 100644 --- a/src/mongo/db/pipeline/sharded_agg_helpers.cpp +++ b/src/mongo/db/pipeline/sharded_agg_helpers.cpp @@ -273,8 +273,11 @@ boost::optional<BSONObj> findSplitPoint(Pipeline::SourceContainer* shardPipe, Pi continue; } - // A source may not simultaneously be present on both sides of the split. - invariant(distributedPlanLogic->shardsStage != distributedPlanLogic->mergingStage); + // TODO SERVER-55491: remove this 'if' to make the invariant unconditional. + if (distributedPlanLogic->shardsStage && distributedPlanLogic->mergingStage) { + // A source may not simultaneously be present on both sides of the split. + invariant(distributedPlanLogic->shardsStage != distributedPlanLogic->mergingStage); + } if (distributedPlanLogic->shardsStage) shardPipe->push_back(std::move(distributedPlanLogic->shardsStage)); |