Update test.

This commit is contained in:
Nikolai Kochetov 2020-03-25 19:55:05 +03:00
parent 7a3daac751
commit 6fd963c805

View File

@ -49,20 +49,21 @@ TEST(Processors, PortsNotConnected)
processors.emplace_back(std::move(source));
processors.emplace_back(std::move(sink));
PipelineExecutor executor(processors);
auto exec = [&]()
{
try
{
PipelineExecutor executor(processors);
executor.execute(1);
}
catch (DB::Exception & e)
{
std::cout << e.displayText() << std::endl;
ASSERT_TRUE(e.displayText().find("pipeline") != std::string::npos);
throw;
}
};
exec();
ASSERT_THROW(exec(), DB::Exception);
}