SERVER-29609 Enable updateLookup for sharded change streams.

1 files changed, 2 insertions, 2 deletions

diff --git a/src/mongo/db/pipeline/document_source_cursor.cpp b/src/mongo/db/pipeline/document_source_cursor.cpp
index 3720c6213df..90449e1b073 100644
--- a/src/mongo/db/pipeline/document_source_cursor.cpp
+++ b/src/mongo/db/pipeline/document_source_cursor.cpp
@@ -106,7 +106,7 @@ void DocumentSourceCursor::loadBatch() {
                 // Furthermore, if we need to return the latest oplog time (in the tailable and
                 // needs-merge case), batching will result in a wrong time.
                 if (shouldWaitForInserts(pExpCtx->opCtx) ||
-                    (pExpCtx->isTailable() && pExpCtx->needsMerge) ||
+                    (pExpCtx->isTailableAwaitData() && pExpCtx->needsMerge) ||
                     memUsageBytes > internalDocumentSourceCursorBatchSizeBytes.load()) {
                     // End this batch and prepare PlanExecutor for yielding.
                     _exec->saveState();
@@ -115,7 +115,7 @@ void DocumentSourceCursor::loadBatch() {
             }
             // Special case for tailable cursor -- EOF doesn't preclude more results, so keep
             // the PlanExecutor alive.
-            if (state == PlanExecutor::IS_EOF && pExpCtx->isTailable()) {
+            if (state == PlanExecutor::IS_EOF && pExpCtx->isTailableAwaitData()) {
                 _exec->saveState();
                 return;
             }