diff options
Diffstat (limited to 'src/mongo/db/commands')
| -rw-r--r-- | src/mongo/db/commands/run_aggregate.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/mongo/db/commands/run_aggregate.cpp b/src/mongo/db/commands/run_aggregate.cpp index 3350f43e4b5..c8d63487229 100644 --- a/src/mongo/db/commands/run_aggregate.cpp +++ b/src/mongo/db/commands/run_aggregate.cpp @@ -409,7 +409,7 @@ Status runAggregate(OperationContext* opCtx, expCtx->tempDir = storageGlobalParams.dbpath + "/_tmp"; if (liteParsedPipeline.hasChangeStream()) { - expCtx->tailableMode = ExpressionContext::TailableMode::kTailableAndAwaitData; + expCtx->tailableMode = TailableMode::kTailableAndAwaitData; } auto pipeline = uassertStatusOK(Pipeline::parse(request.getPipeline(), expCtx)); @@ -471,7 +471,7 @@ Status runAggregate(OperationContext* opCtx, AuthorizationSession::get(opCtx->getClient())->getAuthenticatedUserNames(), opCtx->recoveryUnit()->isReadingFromMajorityCommittedSnapshot(), cmdObj); - if (expCtx->tailableMode == ExpressionContext::TailableMode::kTailableAndAwaitData) { + if (expCtx->tailableMode == TailableMode::kTailableAndAwaitData) { cursorParams.setTailable(true); cursorParams.setAwaitData(true); } |