diff options
Diffstat (limited to 'src/mongo/db/commands/run_aggregate.cpp')
| -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 affce5b9600..e62c2bfd10a 100644 --- a/src/mongo/db/commands/run_aggregate.cpp +++ b/src/mongo/db/commands/run_aggregate.cpp @@ -544,8 +544,8 @@ Status runAggregate(OperationContext* opCtx, // Create a new pipeline for the consumer consisting of a single // DocumentSourceExchange. - boost::intrusive_ptr<DocumentSource> consumer = - new DocumentSourceExchange(expCtx, exchange, idx); + boost::intrusive_ptr<DocumentSource> consumer = new DocumentSourceExchange( + expCtx, exchange, idx, expCtx->mongoProcessInterface->getResourceYielder()); pipelines.emplace_back(uassertStatusOK(Pipeline::create({consumer}, expCtx))); } } else { |