[yt provider] Fix YtReduce type annotation with aux sort columns

YQL-19373
commit_hash:8097d935a27fdc5e71ccee6855681514dcef892b

1 files changed, 6 insertions, 6 deletions

diff --git a/yt/yql/providers/yt/provider/yql_yt_datasink_type_ann.cpp b/yt/yql/providers/yt/provider/yql_yt_datasink_type_ann.cpp
index 4f53f48424..b422af1bf2 100644
--- a/yt/yql/providers/yt/provider/yql_yt_datasink_type_ann.cpp
+++ b/yt/yql/providers/yt/provider/yql_yt_datasink_type_ann.cpp
@@ -250,7 +250,7 @@ private:
         return TStatus::Ok;
     }
 
-    static bool ValidateOutputType(const TTypeAnnotationNode* itemType, TPositionHandle positionHandle, TYtOutSection outTables,
+    static bool ValidateOutputType(const TTypeAnnotationNode* itemType, TPositionHandle positionHandle, const TYtOutSection& outTables,
         size_t beginIdx, size_t endIdx, bool useExtendedType, TExprContext& ctx)
     {
         YQL_ENSURE(beginIdx <= endIdx);
@@ -352,13 +352,13 @@ private:
         return true;
     }
 
-    static bool ValidateOutputType(const TTypeAnnotationNode* itemType, TPositionHandle positionHandle, TYtOutSection outTables,
+    static bool ValidateOutputType(const TTypeAnnotationNode* itemType, TPositionHandle positionHandle, const TYtOutSection& outTables,
         TExprContext& ctx, bool useExtendedType = false)
     {
         return ValidateOutputType(itemType, positionHandle, outTables, 0, outTables.Ref().ChildrenSize(), useExtendedType, ctx);
     }
 
-    static bool ValidateOutputType(const TExprNode& list, TYtOutSection outTables, TExprContext& ctx, bool useExtendedType = false) {
+    static bool ValidateOutputType(const TExprNode& list, const TYtOutSection& outTables, TExprContext& ctx, bool useExtendedType = false) {
         const TTypeAnnotationNode* itemType = GetSequenceItemType(list.Pos(), list.GetTypeAnn(), true, ctx);
         if (nullptr == itemType) {
             return false;
@@ -1144,7 +1144,7 @@ private:
             return TStatus::Error;
         }
 
-        if (!ValidateOutputType(*lambda, map.Output(), ctx, true)) {
+        if (!ValidateOutputType(*lambda, map.Output(), ctx, /*useExtendedType*/true)) {
             lambda->SetTypeAnn(nullptr);
             lambda->SetState(TExprNode::EState::Initial);
             return TStatus::Error;
@@ -1260,7 +1260,7 @@ private:
             return TStatus::Error;
         }
 
-        if (!ValidateOutputType(*lambda, reduce.Output(), ctx)) {
+        if (!ValidateOutputType(*lambda, reduce.Output(), ctx, /*useExtendedType*/true)) {
             lambda->SetTypeAnn(nullptr);
             lambda->SetState(TExprNode::EState::Initial);
             return TStatus::Error;
@@ -1638,7 +1638,7 @@ private:
             return TStatus::Error;
         }
 
-        if (!ValidateOutputType(lambda.Ref(), fill.Output(), ctx, true)) {
+        if (!ValidateOutputType(lambda.Ref(), fill.Output(), ctx, /*useExtendedType*/true)) {
             return TStatus::Error;
         }