Fix yson parsing in yql_agent

2 files changed, 3 insertions, 4 deletions

diff --git a/ydb/library/yql/providers/yt/gateway/native/yql_yt_native.cpp b/ydb/library/yql/providers/yt/gateway/native/yql_yt_native.cpp
index 71fabca7d07..751d1929311 100644
--- a/ydb/library/yql/providers/yt/gateway/native/yql_yt_native.cpp
+++ b/ydb/library/yql/providers/yt/gateway/native/yql_yt_native.cpp
@@ -2982,7 +2982,6 @@ private:
                             execCtx->Options_.OptLLVM()),
                         &columns,
                         execCtx->Options_.FillSettings().Format);
-                    break;
                 default:
                     YQL_LOG_CTX_THROW yexception() << "Invalid result type: " << execCtx->Options_.FillSettings().Format;
             }
diff --git a/ydb/library/yql/providers/yt/lib/res_pull/res_or_pull.cpp b/ydb/library/yql/providers/yt/lib/res_pull/res_or_pull.cpp
index ada1131e5b7..f8da0dbb913 100644
--- a/ydb/library/yql/providers/yt/lib/res_pull/res_or_pull.cpp
+++ b/ydb/library/yql/providers/yt/lib/res_pull/res_or_pull.cpp
@@ -134,9 +134,9 @@ bool TSkiffExecuteResOrPull::WriteNext(const NYT::TNode& item) {
     }
 
     TStringStream err;
-    auto value = NCommon::ParseYsonNode(HolderFactory, item, Specs.Outputs[0].RowType, &err);
+    auto value = NCommon::ParseYsonNodeInResultFormat(HolderFactory, item, Specs.Outputs[0].RowType, &err);
     if (!value) {
-        throw yexception() << "Could not parse yson node";
+        throw yexception() << "Could not parse yson node with error: " << err.Str();
     }
     SkiffWriter.AddRow(*value);
 
@@ -169,7 +169,7 @@ bool TSkiffExecuteResOrPull::WriteNext(TMkqlIOCache& specsCache, const NYT::TNod
     TStringStream err;
     auto value = NCommon::ParseYsonNode(specsCache.GetHolderFactory(), rec, Specs.Outputs[tableIndex].RowType, &err);
     if (!value) {
-        throw yexception() << "Could not parse yson node";
+        throw yexception() << "Could not parse yson node with error: " << err.Str();
     }
     SkiffWriter.AddRow(*value);