aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorziganshinmr <ziganshinmr@yandex-team.com>2025-06-24 12:28:19 +0300
committerziganshinmr <ziganshinmr@yandex-team.com>2025-06-24 12:45:59 +0300
commitfdd4e6a782a2f1d12d00bc0098d3d85d0578f28d (patch)
treec295a7f13345f73893b11656a1d7b8eb3bb0ba37
parentc10afcaf8421dd68ad773c04b3432aad4dd0516f (diff)
downloadydb-fdd4e6a782a2f1d12d00bc0098d3d85d0578f28d.tar.gz
Allow DetermineProgramBlockStatus to visit lambdas
commit_hash:177c73061716d840f82698254ef4c06a6a97b10e
-rw-r--r--yql/essentials/core/yql_opt_utils.cpp4
1 files changed, 3 insertions, 1 deletions
diff --git a/yql/essentials/core/yql_opt_utils.cpp b/yql/essentials/core/yql_opt_utils.cpp
index 76cc1a51500..024d3a0ac6a 100644
--- a/yql/essentials/core/yql_opt_utils.cpp
+++ b/yql/essentials/core/yql_opt_utils.cpp
@@ -2522,8 +2522,10 @@ TOperationProgress::EOpBlockStatus DetermineProgramBlockStatus(const TExprNode&
auto status = IsWideSequenceBlockType(*rootType) ? TOperationProgress::EOpBlockStatus::Full : TOperationProgress::EOpBlockStatus::None;
bool stop = false;
VisitExpr(*pRoot, [&](const TExprNode& node) {
- if (stop || node.IsLambda()) {
+ if (stop || node.IsArguments()) {
return false;
+ } else if (node.IsLambda()) {
+ return true;
}
const TTypeAnnotationNode* nodeType = node.GetTypeAnn();