diff options
| author | vvvv <[email protected]> | 2025-02-21 18:08:26 +0300 |
|---|---|---|
| committer | vvvv <[email protected]> | 2025-02-21 19:12:56 +0300 |
| commit | 807412ee4958d5903d6bb22cfb95ea126919c6f9 (patch) | |
| tree | 94e95014f93ccb0e440dd0d16cb4fe4d52a8d269 /yql/essentials/minikql/computation | |
| parent | 253d0dcf6c3fbbbf0594538d398123fc4eb9ae68 (diff) | |
YQL-19593 better error handling for Udf
commit_hash:216229b0558e1004453dedddbec8b767b2dab9c6
Diffstat (limited to 'yql/essentials/minikql/computation')
| -rw-r--r-- | yql/essentials/minikql/computation/mkql_computation_node_graph.cpp | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/yql/essentials/minikql/computation/mkql_computation_node_graph.cpp b/yql/essentials/minikql/computation/mkql_computation_node_graph.cpp index e1a79dff5b1..75bcc4ce5cf 100644 --- a/yql/essentials/minikql/computation/mkql_computation_node_graph.cpp +++ b/yql/essentials/minikql/computation/mkql_computation_node_graph.cpp @@ -164,6 +164,10 @@ public: } } + ITerminator& GetTerminator() { + return *ValueBuilder; + } + const TComputationMutables& GetMutables() const { return Mutables; } @@ -994,6 +998,7 @@ TIntrusivePtr<TComputationPatternImpl> MakeComputationPatternImpl(TExploringNode depScanner.Walk(root.GetNode(), opts.Env); auto builder = MakeHolder<TComputationGraphBuildingVisitor>(opts); + const TBindTerminator bind(&builder->GetPatternNodes()->GetTerminator()); for (const auto& node : explorer.GetNodes()) { Y_ABORT_UNLESS(node->GetCookie() <= IS_NODE_REACHABLE, "TNode graph should not be reused"); if (node->GetCookie() == IS_NODE_REACHABLE) { |