diff options
Diffstat (limited to 'src/mongo/dbtests')
-rw-r--r-- | src/mongo/dbtests/query_plan_executor.cpp | 16 | ||||
-rw-r--r-- | src/mongo/dbtests/query_stage_multiplan.cpp | 2 |
2 files changed, 4 insertions, 14 deletions
diff --git a/src/mongo/dbtests/query_plan_executor.cpp b/src/mongo/dbtests/query_plan_executor.cpp index 4ed8b61720b..075ededc8e9 100644 --- a/src/mongo/dbtests/query_plan_executor.cpp +++ b/src/mongo/dbtests/query_plan_executor.cpp @@ -42,7 +42,6 @@ #include "mongo/db/exec/collection_scan.h" #include "mongo/db/exec/fetch.h" #include "mongo/db/exec/index_scan.h" -#include "mongo/db/exec/pipeline_proxy.h" #include "mongo/db/exec/plan_stage.h" #include "mongo/db/exec/working_set_common.h" #include "mongo/db/json.h" @@ -51,6 +50,7 @@ #include "mongo/db/pipeline/document_source_cursor.h" #include "mongo/db/pipeline/expression_context_for_test.h" #include "mongo/db/pipeline/pipeline.h" +#include "mongo/db/pipeline/plan_executor_pipeline.h" #include "mongo/db/query/plan_executor_factory.h" #include "mongo/db/query/query_solution.h" #include "mongo/dbtests/dbtests.h" @@ -223,18 +223,8 @@ TEST_F(PlanExecutorTest, DropIndexScanAgg) { collection, std::move(innerExec), _expCtx, DocumentSourceCursor::CursorType::kRegular); auto pipeline = Pipeline::create({cursorSource}, _expCtx); - // Create the output PlanExecutor that pulls results from the pipeline. - auto ws = std::make_unique<WorkingSet>(); - auto proxy = std::make_unique<PipelineProxyStage>(_expCtx.get(), std::move(pipeline), ws.get()); - - auto statusWithPlanExecutor = - plan_executor_factory::make(_expCtx, - std::move(ws), - std::move(proxy), - collection, - PlanYieldPolicy::YieldPolicy::NO_YIELD); - ASSERT_OK(statusWithPlanExecutor.getStatus()); - auto outerExec = std::move(statusWithPlanExecutor.getValue()); + auto outerExec = + plan_executor_factory::make(_expCtx, std::move(pipeline), false /* isChangeStream */); dropCollection(); diff --git a/src/mongo/dbtests/query_stage_multiplan.cpp b/src/mongo/dbtests/query_stage_multiplan.cpp index aa9abb89be2..83337ca69ec 100644 --- a/src/mongo/dbtests/query_stage_multiplan.cpp +++ b/src/mongo/dbtests/query_stage_multiplan.cpp @@ -556,7 +556,7 @@ TEST_F(QueryStageMultiPlanTest, MPSSummaryStats) { exec->executePlan(); PlanSummaryStats stats; - Explain::getSummaryStats(*exec, &stats); + exec->getSummaryStats(&stats); // If only the winning plan's stats are recorded, we should not have examined more than the // total number of documents/index keys. |