Fix test.

This commit is contained in:
Nikolai Kochetov 2022-06-02 21:29:29 +00:00
parent 176af473c3
commit 468c04ee66

View File

@ -219,6 +219,10 @@ void ReadFromRemote::initializePipeline(QueryPipelineBuilder & pipeline, const B
}
auto pipe = Pipe::unitePipes(std::move(pipes));
for (const auto & processor : pipe.getProcessors())
processor->setStorageLimits(storage_limits);
pipeline.init(std::move(pipe));
}