Block output for YT operations

commit_hash:469d6669ff3d3216234cac1ac27e03e22600aff8

2 files changed, 2 insertions, 0 deletions

diff --git a/yql/tools/yqlrun/http/yql_server.cpp b/yql/tools/yqlrun/http/yql_server.cpp
index 4cefa52396..97fe9e671c 100644
--- a/yql/tools/yqlrun/http/yql_server.cpp
+++ b/yql/tools/yqlrun/http/yql_server.cpp
@@ -106,6 +106,7 @@ public:
         pipeline->Add(CreateYtWideFlowTransformer(nullptr), "WideFlow");
         pipeline->Add(CreateYtBlockInputTransformer(nullptr), "BlockInput");
         pipeline->Add(MakePeepholeOptimization(pipeline->GetTypeAnnotationContext()), "PeepHole");
+        pipeline->Add(CreateYtBlockOutputTransformer(nullptr), "BlockOutput");
     }
 };
 
diff --git a/yql/tools/yqlrun/lib/yqlrun_lib.cpp b/yql/tools/yqlrun/lib/yqlrun_lib.cpp
index f8b681a456..d9db2a9048 100644
--- a/yql/tools/yqlrun/lib/yqlrun_lib.cpp
+++ b/yql/tools/yqlrun/lib/yqlrun_lib.cpp
@@ -33,6 +33,7 @@ public:
         pipeline->Add(NYql::CreateYtWideFlowTransformer(nullptr), "WideFlow");
         pipeline->Add(NYql::CreateYtBlockInputTransformer(nullptr), "BlockInput");
         pipeline->Add(NYql::MakePeepholeOptimization(pipeline->GetTypeAnnotationContext()), "PeepHole");
+        pipeline->Add(NYql::CreateYtBlockOutputTransformer(nullptr), "BlockOutput");
     }
 };