diff options
Diffstat (limited to 'src/mongo/db/commands/cqf/cqf_aggregate.cpp')
| -rw-r--r-- | src/mongo/db/commands/cqf/cqf_aggregate.cpp | 10 |
1 files changed, 2 insertions, 8 deletions
diff --git a/src/mongo/db/commands/cqf/cqf_aggregate.cpp b/src/mongo/db/commands/cqf/cqf_aggregate.cpp index 30cdc8c3846..100da0be582 100644 --- a/src/mongo/db/commands/cqf/cqf_aggregate.cpp +++ b/src/mongo/db/commands/cqf/cqf_aggregate.cpp @@ -29,7 +29,6 @@ #include "mongo/db/commands/cqf/cqf_aggregate.h" -#include "mongo/db/curop.h" #include "mongo/db/exec/sbe/abt/abt_lower.h" #include "mongo/db/pipeline/abt/abt_document_source_visitor.h" #include "mongo/db/pipeline/abt/match_expression_visitor.h" @@ -63,8 +62,7 @@ static opt::unordered_map<std::string, optimizer::IndexDefinition> buildIndexSpe const IndexCatalog& indexCatalog = *collection->getIndexCatalog(); opt::unordered_map<std::string, IndexDefinition> result; - auto indexIterator = - indexCatalog.getIndexIterator(opCtx, IndexCatalog::InclusionPolicy::kReady); + auto indexIterator = indexCatalog.getIndexIterator(opCtx, false /*includeUnfinished*/); while (indexIterator->more()) { const IndexCatalogEntry& catalogEntry = *indexIterator->next(); @@ -257,8 +255,7 @@ static std::unique_ptr<PlanExecutor, PlanExecutor::Deleter> optimizeAndCreateExe } auto yieldPolicy = - std::make_unique<PlanYieldPolicySBE>(opCtx, - PlanYieldPolicy::YieldPolicy::YIELD_AUTO, + std::make_unique<PlanYieldPolicySBE>(PlanYieldPolicy::YieldPolicy::YIELD_AUTO, opCtx->getServiceContext()->getFastClockSource(), internalQueryExecYieldIterations.load(), Milliseconds{internalQueryExecYieldPeriodMS.load()}, @@ -338,9 +335,6 @@ std::unique_ptr<PlanExecutor, PlanExecutor::Deleter> getSBEExecutorViaCascadesOp const std::string collNameStr = nss.coll().toString(); const std::string scanDefName = collNameStr + "_" + uuidStr; - auto curOp = CurOp::get(opCtx); - curOp->debug().cqfUsed = true; - QueryHints queryHints = getHintsFromQueryKnobs(); PrefixId prefixId; |