Function checkOutput

src/QueryPipeline/QueryPipeline.cpp:75–88

}

static void checkOutput(const OutputPort & output, const ProcessorPtr & processor, const Processors & processors = {})
{
    if (!output.isConnected())
    {
        WriteBufferFromOwnString out;
        if (!processors.empty())
            printPipeline(processors, out);

        throw Exception(
            ErrorCodes::LOGICAL_ERROR,
            "Cannot create QueryPipeline because {} {} has disconnected output: {}",
            processor->getName(), processor->getDescription(), out.str());
    }
}

static void checkPulling(
    Processors & processors,