diff options
4 files changed, 60 insertions, 4 deletions
diff --git a/ydb/library/yql/core/services/yql_lineage.cpp b/ydb/library/yql/core/services/yql_lineage.cpp index 3065c5eb6d1..c978d2e260f 100644 --- a/ydb/library/yql/core/services/yql_lineage.cpp +++ b/ydb/library/yql/core/services/yql_lineage.cpp @@ -246,10 +246,6 @@ private: return Nothing(); } - if (node.IsArgument()) { - return Nothing(); - } - auto [it, inserted] = visited.emplace(&node, Nothing()); if (!inserted) { return it->second; diff --git a/ydb/library/yql/tests/sql/sql2yql/canondata/result.json b/ydb/library/yql/tests/sql/sql2yql/canondata/result.json index f0924e433e0..7d0288dc0d7 100644 --- a/ydb/library/yql/tests/sql/sql2yql/canondata/result.json +++ b/ydb/library/yql/tests/sql/sql2yql/canondata/result.json @@ -9435,6 +9435,13 @@ "uri": "https://{canondata_backend}/1689644/39ce6d9afd6582130ac864f33dffbf252ff73f8a/resource.tar.gz#test_sql2yql.test_lineage-member_over_if_struct_/sql.yql" } ], + "test_sql2yql.test[lineage-nested_lambda_fields]": [ + { + "checksum": "7f27c8f0aff32fce7b86d9d370733164", + "size": 1538, + "uri": "https://{canondata_backend}/1937001/367147bfd772fc8975087ce9c3bf4c808edc62a9/resource.tar.gz#test_sql2yql.test_lineage-nested_lambda_fields_/sql.yql" + } + ], "test_sql2yql.test[lineage-scalar_context]": [ { "checksum": "d30139e2ac069a234955b9b89fe80997", @@ -26536,6 +26543,13 @@ "uri": "https://{canondata_backend}/1880306/64654158d6bfb1289c66c626a8162239289559d0/resource.tar.gz#test_sql_format.test_lineage-member_over_if_struct_/formatted.sql" } ], + "test_sql_format.test[lineage-nested_lambda_fields]": [ + { + "checksum": "18ff9032fab9ba6187699e80a1885eb3", + "size": 210, + "uri": "https://{canondata_backend}/1937001/367147bfd772fc8975087ce9c3bf4c808edc62a9/resource.tar.gz#test_sql_format.test_lineage-nested_lambda_fields_/formatted.sql" + } + ], "test_sql_format.test[lineage-scalar_context]": [ { "checksum": "676d826944ab5b018d11e541237afbf2", diff --git a/ydb/library/yql/tests/sql/suites/lineage/nested_lambda_fields.sql b/ydb/library/yql/tests/sql/suites/lineage/nested_lambda_fields.sql new file mode 100644 index 00000000000..9091bae31ec --- /dev/null +++ b/ydb/library/yql/tests/sql/suites/lineage/nested_lambda_fields.sql @@ -0,0 +1,18 @@ +USE plato; + +$v = ($x) -> { + return ListFilter(["a","b"],($y)->($y = $x)); +}; + +$k = ($x) -> { + return $x; +}; + + +insert into Output +with truncate +select + $k(key) as k, + $v(value) as v +from + Input diff --git a/ydb/library/yql/tests/sql/yt_native_file/part8/canondata/result.json b/ydb/library/yql/tests/sql/yt_native_file/part8/canondata/result.json index 12f312f2085..4b5157a8c54 100644 --- a/ydb/library/yql/tests/sql/yt_native_file/part8/canondata/result.json +++ b/ydb/library/yql/tests/sql/yt_native_file/part8/canondata/result.json @@ -3105,6 +3105,34 @@ "uri": "https://{canondata_backend}/1900335/4871e48d29e4933514d3ed0c9c5d19de571eda1f/resource.tar.gz#test.test_like-regexp_clause--Results_/results.txt" } ], + "test.test[lineage-nested_lambda_fields-default.txt-Debug]": [ + { + "checksum": "b2c3fb3345ce583bf1f7484f6d75c067", + "size": 1595, + "uri": "https://{canondata_backend}/1871002/6e0d911110d361003b7b42e0f8d60544da3e8401/resource.tar.gz#test.test_lineage-nested_lambda_fields-default.txt-Debug_/opt.yql" + } + ], + "test.test[lineage-nested_lambda_fields-default.txt-Lineage]": [ + { + "checksum": "d1aa35d780e50196cc693156608fa3bd", + "size": 1232, + "uri": "https://{canondata_backend}/1871002/6e0d911110d361003b7b42e0f8d60544da3e8401/resource.tar.gz#test.test_lineage-nested_lambda_fields-default.txt-Lineage_/results.txt" + } + ], + "test.test[lineage-nested_lambda_fields-default.txt-Plan]": [ + { + "checksum": "5fb9569d3f2c86ed9c9a7a85c93cfef3", + "size": 5114, + "uri": "https://{canondata_backend}/1871002/6e0d911110d361003b7b42e0f8d60544da3e8401/resource.tar.gz#test.test_lineage-nested_lambda_fields-default.txt-Plan_/plan.txt" + } + ], + "test.test[lineage-nested_lambda_fields-default.txt-Results]": [ + { + "checksum": "52c638c8c836a17d7c1d84ab95e21836", + "size": 80, + "uri": "https://{canondata_backend}/1871002/6e0d911110d361003b7b42e0f8d60544da3e8401/resource.tar.gz#test.test_lineage-nested_lambda_fields-default.txt-Results_/Output.txt" + } + ], "test.test[lineage-select_group_by_key-default.txt-Debug]": [ { "checksum": "57d55d2339b5b53be558a0906642c6b5", |