diff --git a/src/QueryPipeline/QueryPipeline.cpp b/src/QueryPipeline/QueryPipeline.cpp
index 9a836f68da1..1ad3ddf9d6f 100644
--- a/src/QueryPipeline/QueryPipeline.cpp
+++ b/src/QueryPipeline/QueryPipeline.cpp
@@ -353,6 +353,7 @@ QueryPipeline::QueryPipeline(Pipe pipe)
         totals = pipe.getTotalsPort();
         extremes = pipe.getExtremesPort();
         partial_result = pipe.getPartialResultPort(0);
+        num_threads = pipe.max_parallel_streams;
 
         processors = std::move(pipe.processors);
         checkPulling(*processors, output, totals, extremes, partial_result);