Merge branch 'rightlib' into mergelibs-241120-1113

159 files changed, 1604 insertions, 0 deletions

diff --git a/yql/essentials/tests/sql/suites/action/action_eval_cluster_and_table.sql b/yql/essentials/tests/sql/suites/action/action_eval_cluster_and_table.sql
new file mode 100644
index 0000000000..414f54ac9d
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/action_eval_cluster_and_table.sql
@@ -0,0 +1,8 @@
+/* syntax version 1 */
+/* postgres can not */
+$cluster = "pla" || "to";
+$name = "In" || "put";
+
+SELECT
+    count(*)
+FROM yt:$cluster.$name;
diff --git a/yql/essentials/tests/sql/suites/action/action_eval_cluster_table.cfg b/yql/essentials/tests/sql/suites/action/action_eval_cluster_table.cfg
new file mode 100644
index 0000000000..386ab9ac7f
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/action_eval_cluster_table.cfg
@@ -0,0 +1,3 @@
+in Input input.txt
+out Output output.txt
+udf string_udf
diff --git a/yql/essentials/tests/sql/suites/action/action_eval_cluster_table.sql b/yql/essentials/tests/sql/suites/action/action_eval_cluster_table.sql
new file mode 100644
index 0000000000..67e2af6063
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/action_eval_cluster_table.sql
@@ -0,0 +1,9 @@
+/* syntax version 1 */
+/* postgres can not */
+$foo = CAST(Unicode::ToLower("PLATO"u) AS String);
+
+insert into yt:$foo.Output
+select *
+from yt:$foo.Input
+where key < "100"
+order by key;
diff --git a/yql/essentials/tests/sql/suites/action/action_eval_cluster_table_for.cfg b/yql/essentials/tests/sql/suites/action/action_eval_cluster_table_for.cfg
new file mode 100644
index 0000000000..386ab9ac7f
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/action_eval_cluster_table_for.cfg
@@ -0,0 +1,3 @@
+in Input input.txt
+out Output output.txt
+udf string_udf
diff --git a/yql/essentials/tests/sql/suites/action/action_eval_cluster_table_for.sql b/yql/essentials/tests/sql/suites/action/action_eval_cluster_table_for.sql
new file mode 100644
index 0000000000..56554226fe
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/action_eval_cluster_table_for.sql
@@ -0,0 +1,14 @@
+/* syntax version 1 */
+/* postgres can not */
+define action $a($x) as
+    $foo = CAST(Unicode::ToLower($x) AS String);
+
+    insert into yt:$foo.Output
+    select *
+    from yt:$foo.Input
+    where key < "100"
+    order by key;
+
+end define;
+
+evaluate for $i in AsList("PLATO"u) do $a($i);
diff --git a/yql/essentials/tests/sql/suites/action/action_eval_cluster_use.cfg b/yql/essentials/tests/sql/suites/action/action_eval_cluster_use.cfg
new file mode 100644
index 0000000000..386ab9ac7f
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/action_eval_cluster_use.cfg
@@ -0,0 +1,3 @@
+in Input input.txt
+out Output output.txt
+udf string_udf
diff --git a/yql/essentials/tests/sql/suites/action/action_eval_cluster_use.sql b/yql/essentials/tests/sql/suites/action/action_eval_cluster_use.sql
new file mode 100644
index 0000000000..7635ba2d17
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/action_eval_cluster_use.sql
@@ -0,0 +1,10 @@
+/* syntax version 1 */
+/* postgres can not */
+$foo = CAST(Unicode::ToLower("PLATO"u) AS String);
+use yt:$foo;
+
+insert into Output
+select *
+from Input
+where key < "100"
+order by key;
diff --git a/yql/essentials/tests/sql/suites/action/action_eval_cluster_use_compact_named_exprs.cfg b/yql/essentials/tests/sql/suites/action/action_eval_cluster_use_compact_named_exprs.cfg
new file mode 100644
index 0000000000..fccca71d35
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/action_eval_cluster_use_compact_named_exprs.cfg
@@ -0,0 +1,3 @@
+in Input input.txt
+out Output output.txt
+providers yt
diff --git a/yql/essentials/tests/sql/suites/action/action_eval_cluster_use_compact_named_exprs.sql b/yql/essentials/tests/sql/suites/action/action_eval_cluster_use_compact_named_exprs.sql
new file mode 100644
index 0000000000..08994c5615
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/action_eval_cluster_use_compact_named_exprs.sql
@@ -0,0 +1,20 @@
+/* yt can not */
+pragma CompactNamedExprs;
+$foo = CAST(Unicode::ToLower("PLATO"u) AS String);
+
+insert into yt:$foo.Output
+select *
+from yt:$foo.Input
+where key < "100"
+order by key;
+
+define action $bar() as
+   $x = CAST(Unicode::ToLower("PLaTO"u) AS String);
+   insert into yt:$x.Output
+   select *
+   from yt:$foo.Input
+   where key < "100"
+   order by key;
+end define;
+
+do $bar();
diff --git a/yql/essentials/tests/sql/suites/action/action_nested_query.sql b/yql/essentials/tests/sql/suites/action/action_nested_query.sql
new file mode 100644
index 0000000000..0d6e87d794
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/action_nested_query.sql
@@ -0,0 +1,10 @@
+/* syntax version 1 */
+/* postgres can not */
+use plato;
+
+define action $action() as
+  $sub = (select * from Input);
+  select * from $sub order by key;
+end define;
+
+do $action();
diff --git a/yql/essentials/tests/sql/suites/action/action_opt_args.sql b/yql/essentials/tests/sql/suites/action/action_opt_args.sql
new file mode 100644
index 0000000000..b577b12a5d
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/action_opt_args.sql
@@ -0,0 +1,8 @@
+/* syntax version 1 */
+/* postgres can not */
+define action $action($a,$b?) as
+    select $a + ($b ?? 0);
+end define;
+
+do $action(1);
+do $action(2, 3);
diff --git a/yql/essentials/tests/sql/suites/action/action_udf_args.cfg b/yql/essentials/tests/sql/suites/action/action_udf_args.cfg
new file mode 100644
index 0000000000..386ab9ac7f
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/action_udf_args.cfg
@@ -0,0 +1,3 @@
+in Input input.txt
+out Output output.txt
+udf string_udf
diff --git a/yql/essentials/tests/sql/suites/action/action_udf_args.sql b/yql/essentials/tests/sql/suites/action/action_udf_args.sql
new file mode 100644
index 0000000000..16f7eefcaf
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/action_udf_args.sql
@@ -0,0 +1,8 @@
+/* syntax version 1 */
+/* postgres can not */
+define action $f($x) as
+    select $x;
+end define;
+
+$x = CAST(Unicode::ToUpper("abc"u) AS String);
+do $f($x);
diff --git a/yql/essentials/tests/sql/suites/action/closure_action.sql b/yql/essentials/tests/sql/suites/action/closure_action.sql
new file mode 100644
index 0000000000..3008cf3a1c
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/closure_action.sql
@@ -0,0 +1,14 @@
+/* syntax version 1 */
+/* postgres can not */
+define action $action($b,$c) as
+    $d = $b + $c;
+    select $b;
+    select $c;
+    select $d;
+end define;
+
+define action $closure_action($a) as
+  do $a(3,4);
+end define;
+
+do $closure_action($action);
diff --git a/yql/essentials/tests/sql/suites/action/combine_subqueries_with_table_param.sql b/yql/essentials/tests/sql/suites/action/combine_subqueries_with_table_param.sql
new file mode 100644
index 0000000000..542493b3af
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/combine_subqueries_with_table_param.sql
@@ -0,0 +1,22 @@
+/* syntax version 1 */
+/* postgres can not */
+use plato;
+
+$combineQueries = ($query, $list) -> {
+    RETURN EvaluateCode(LambdaCode(($world) -> {
+        $queries = ListMap($list, ($arg)->{
+                RETURN FuncCode("Apply", QuoteCode($query), $world, ReprCode($arg))
+            });
+
+        RETURN FuncCode("UnionAll", $queries);
+    }));
+};
+
+DEFINE SUBQUERY $calc($table) AS
+    SELECT *
+    FROM $table;
+END DEFINE;
+
+$fullQuery = $combineQueries($calc, AsList("Input", "Input"));
+
+SELECT count(*) FROM $fullQuery();
diff --git a/yql/essentials/tests/sql/suites/action/default.cfg b/yql/essentials/tests/sql/suites/action/default.cfg
new file mode 100644
index 0000000000..ad52c79527
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/default.cfg
@@ -0,0 +1,2 @@
+in Input input.txt
+out Output output.txt
diff --git a/yql/essentials/tests/sql/suites/action/define_simple_action.sql b/yql/essentials/tests/sql/suites/action/define_simple_action.sql
new file mode 100644
index 0000000000..60244b3b48
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/define_simple_action.sql
@@ -0,0 +1,10 @@
+/* syntax version 1 */
+/* postgres can not */
+define action $action($b,$c) as
+    $d = $b + $c;
+    select $b;
+    select $c;
+    select $d;
+end define;
+
+do $action(1,2);
diff --git a/yql/essentials/tests/sql/suites/action/dep_world_action_quote.sql b/yql/essentials/tests/sql/suites/action/dep_world_action_quote.sql
new file mode 100644
index 0000000000..6375e06aee
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/dep_world_action_quote.sql
@@ -0,0 +1,20 @@
+/* syntax version 1 */
+/* postgres can not */
+use plato;
+
+DEFINE ACTION $aaa($z) as 
+
+$table = $z.0;
+$k = (select min(key || $z.1) from $table);
+
+DEFINE ACTION $bbb($n) AS
+   SELECT $n || $k FROM $table;
+END DEFINE;
+
+$ccc = EvaluateCode(QuoteCode($bbb));
+DO $ccc("1");
+
+END DEFINE;
+
+EVALUATE FOR $z IN AsList(AsTuple("Input","foo"),AsTuple("Input","bar")) 
+    DO $aaa($z);
diff --git a/yql/essentials/tests/sql/suites/action/dep_world_quote_code.sql b/yql/essentials/tests/sql/suites/action/dep_world_quote_code.sql
new file mode 100644
index 0000000000..6188630666
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/dep_world_quote_code.sql
@@ -0,0 +1,31 @@
+/* syntax version 1 */
+/* postgres can not */
+use plato;
+
+$combineQueries = ($query, $list) -> {
+    RETURN EvaluateCode(LambdaCode(($world) -> {
+        $queries = ListMap($list, ($arg) -> {
+                RETURN FuncCode("Apply", QuoteCode($query), $world, ReprCode($arg))
+            });
+
+        RETURN FuncCode("Extend", $queries);
+    }));
+};
+
+DEFINE ACTION $aaa($z) as 
+
+$k = (select count(*) from $z);
+
+DEFINE SUBQUERY $sub($n) AS
+   SELECT $n + $k FROM $z;
+END DEFINE;
+
+$fullQuery = $combineQueries($sub, ListFromRange(0, 10));
+SELECT * FROM $fullQuery();
+
+END DEFINE;
+
+EVALUATE FOR $z IN AsList("Input") 
+    DO $aaa($z);
+ 
+DO $aaa("Input");
diff --git a/yql/essentials/tests/sql/suites/action/discard.sql b/yql/essentials/tests/sql/suites/action/discard.sql
new file mode 100644
index 0000000000..ccdac00de8
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/discard.sql
@@ -0,0 +1,32 @@
+/* syntax version 1 */
+/* postgres can not */
+define subquery $a() as
+$_x = select 1;
+discard
+select ensure(1, true);
+select 2;
+$_y = select 2;
+end define;
+
+process $a();
+
+
+define subquery $b() as
+$f1 = ($row)->(<|a:1,b:$row.value|>);
+$f2 = ($row)->(<|a:2,b:$row.value|>);
+discard 
+process plato.Input using $f1(TableRow());
+process plato.Input using $f2(TableRow());
+end define;
+
+select * from $b() order by b limit 1;
+
+define subquery $c() as
+$f1 = ($key,$_)->(<|a:1,b:$key|>);
+$f2 = ($key,$_)->(<|a:2,b:$key|>);
+discard 
+reduce plato.Input on key using $f1(TableRow());
+reduce plato.Input on key using $f2(TableRow());
+end define;
+
+select * from $c() order by b limit 1;
diff --git a/yql/essentials/tests/sql/suites/action/empty_do.sql b/yql/essentials/tests/sql/suites/action/empty_do.sql
new file mode 100644
index 0000000000..3b30a5803c
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/empty_do.sql
@@ -0,0 +1,13 @@
+/* syntax version 1 */
+/* postgres can not */
+do empty_action();
+
+$action1 = empty_action;
+
+do $action1();
+
+$action2 = ($a,$_b)->{
+   return $a;
+};
+
+do $action2(12);
diff --git a/yql/essentials/tests/sql/suites/action/eval_anon_table.cfg b/yql/essentials/tests/sql/suites/action/eval_anon_table.cfg
new file mode 100644
index 0000000000..ad52c79527
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_anon_table.cfg
@@ -0,0 +1,2 @@
+in Input input.txt
+out Output output.txt
diff --git a/yql/essentials/tests/sql/suites/action/eval_anon_table.sql b/yql/essentials/tests/sql/suites/action/eval_anon_table.sql
new file mode 100644
index 0000000000..449fbd3b83
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_anon_table.sql
@@ -0,0 +1,13 @@
+/* syntax version 1 */
+/* postgres can not */
+USE plato;
+
+$a = CAST(Unicode::ToUpper("T"u) AS String) || "able";
+$b = CAST(Unicode::ToUpper("T"u) AS String) || "able";
+
+insert into @$a
+select 1 as x;
+
+commit;
+
+select * from @$b;
diff --git a/yql/essentials/tests/sql/suites/action/eval_asatom.sql b/yql/essentials/tests/sql/suites/action/eval_asatom.sql
new file mode 100644
index 0000000000..ca169899ed
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_asatom.sql
@@ -0,0 +1,3 @@
+/* syntax version 1 */
+/* postgres can not */
+SELECT Yql::String(AsAtom("a" || CAST(Unicode::ToUpper("b"u) AS String)));
diff --git a/yql/essentials/tests/sql/suites/action/eval_astagged.sql b/yql/essentials/tests/sql/suites/action/eval_astagged.sql
new file mode 100644
index 0000000000..89c4b9bcab
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_astagged.sql
@@ -0,0 +1,3 @@
+/* syntax version 1 */
+/* postgres can not */
+SELECT AsTagged(0, CAST(Unicode::ToUpper("t"u) AS String) || "ag");
diff --git a/yql/essentials/tests/sql/suites/action/eval_atom_wrong_type_expr.cfg b/yql/essentials/tests/sql/suites/action/eval_atom_wrong_type_expr.cfg
new file mode 100644
index 0000000000..bc27f4ed21
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_atom_wrong_type_expr.cfg
@@ -0,0 +1,3 @@
+xfail
+providers yt
+
diff --git a/yql/essentials/tests/sql/suites/action/eval_atom_wrong_type_expr.sql b/yql/essentials/tests/sql/suites/action/eval_atom_wrong_type_expr.sql
new file mode 100644
index 0000000000..9e8a2a8c6e
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_atom_wrong_type_expr.sql
@@ -0,0 +1,7 @@
+/* yt can not */
+use plato;
+
+$n = ["foo"];
+
+select * from $n;
+
diff --git a/yql/essentials/tests/sql/suites/action/eval_atom_wrong_type_param.cfg b/yql/essentials/tests/sql/suites/action/eval_atom_wrong_type_param.cfg
new file mode 100644
index 0000000000..bc27f4ed21
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_atom_wrong_type_param.cfg
@@ -0,0 +1,3 @@
+xfail
+providers yt
+
diff --git a/yql/essentials/tests/sql/suites/action/eval_atom_wrong_type_param.sql b/yql/essentials/tests/sql/suites/action/eval_atom_wrong_type_param.sql
new file mode 100644
index 0000000000..7de917ef03
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_atom_wrong_type_param.sql
@@ -0,0 +1,7 @@
+/* yt can not */
+use plato;
+
+declare $n as List<String>?;
+
+select * from $n;
+
diff --git a/yql/essentials/tests/sql/suites/action/eval_capture.cfg b/yql/essentials/tests/sql/suites/action/eval_capture.cfg
new file mode 100644
index 0000000000..c6a659f7de
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_capture.cfg
@@ -0,0 +1,3 @@
+in Input input.txt
+out Output output.txt
+udf re2_udf
diff --git a/yql/essentials/tests/sql/suites/action/eval_capture.sql b/yql/essentials/tests/sql/suites/action/eval_capture.sql
new file mode 100644
index 0000000000..b60a8c4a2a
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_capture.sql
@@ -0,0 +1,4 @@
+/* syntax version 1 */
+/* postgres can not */
+$capture = Re2::Capture(".*" || CAST(Unicode::ToLower("(\\D+)"u) AS String) || ".*");
+SELECT $capture(" 123 ");
diff --git a/yql/essentials/tests/sql/suites/action/eval_code.sql b/yql/essentials/tests/sql/suites/action/eval_code.sql
new file mode 100644
index 0000000000..10d0360aea
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_code.sql
@@ -0,0 +1,22 @@
+/* syntax version 1 */
+/* postgres can not */
+select EvaluateCode(FuncCode("Int32",AtomCode("1")));
+
+$inc = EvaluateCode(LambdaCode(($x)->{return 
+    FuncCode("+", $x, FuncCode("Int32", AtomCode("1")))}));
+select $inc(1);
+
+$addPrefixForMembers = ($strValue)->{
+    $code = EvaluateCode(LambdaCode(($str)->{
+        $members = StructTypeComponents(TypeHandle(TypeOf($strValue)));
+        $list = ListMap($members, ($x)->{
+            return ListCode(AtomCode("prefix" || $x.Name),FuncCode("Member", $str, AtomCode($x.Name)));
+        });
+
+        return FuncCode("AsStruct",$list);
+    }));
+    return $code($strValue);
+};
+
+select $addPrefixForMembers(AsStruct(1 as foo, "2" as bar));
+
diff --git a/yql/essentials/tests/sql/suites/action/eval_code_nested.sql b/yql/essentials/tests/sql/suites/action/eval_code_nested.sql
new file mode 100644
index 0000000000..e730cf7d71
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_code_nested.sql
@@ -0,0 +1,18 @@
+/* syntax version 1 */
+/* postgres can not */
+select EvaluateCode(
+    ReprCode(1));
+
+select EvaluateCode(
+    FuncCode("EvaluateCode",
+    FuncCode("ReprCode", ReprCode(1))));
+
+select EvaluateCode(
+    FuncCode("EvaluateCode",
+        FuncCode("ReprCode", 
+            FuncCode("EvaluateCode",
+                FuncCode("ReprCode", ReprCode(1))))));
+
+select EvaluateCode(
+    FuncCode("EvaluateExpr",
+    QuoteCode(1 + 2)));
diff --git a/yql/essentials/tests/sql/suites/action/eval_column.cfg b/yql/essentials/tests/sql/suites/action/eval_column.cfg
new file mode 100644
index 0000000000..c6596e362c
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_column.cfg
@@ -0,0 +1,2 @@
+in Input input.txt
+udf string_udf
diff --git a/yql/essentials/tests/sql/suites/action/eval_column.sql b/yql/essentials/tests/sql/suites/action/eval_column.sql
new file mode 100644
index 0000000000..98838fb5fe
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_column.sql
@@ -0,0 +1,34 @@
+/* syntax version 1 */
+/* postgres can not */
+use plato;
+
+$x = CAST(Unicode::ToLower("foo"u) AS String);
+select AsStruct("1" as foo, 2 as bar).$x;
+
+$x = CAST(Unicode::ToLower("value"u) AS String);
+select key, t.$x from Input as t order by key;
+
+$x = CAST(Unicode::ToLower("value"u) AS String);
+select key, TableRow().$x from Input order by key;
+
+
+$x = CAST(Unicode::ToLower("value"u) AS String);
+select * from Input as t order by t.$x;
+
+$x = CAST(Unicode::ToLower("value"u) AS String);
+$y = CAST(Unicode::ToLower("key"u) AS String);
+
+select x,count(*) from Input as t group by t.$x as x
+having min(t.$y) != ""
+order by x;
+
+select a.$x as x,b.$y as y from Input as a join Input as b on (a.$x = b.$x)
+order by x;
+
+select a.$x as x,b.$y as y from Input as a join Input as b using ($x)
+order by x;
+
+select p, value, lag(value) over w as lag
+from Input
+window w as (partition by TableRow().$y as p order by TableRow().$x)
+order by p, value;
diff --git a/yql/essentials/tests/sql/suites/action/eval_drop.cfg b/yql/essentials/tests/sql/suites/action/eval_drop.cfg
new file mode 100644
index 0000000000..58878f8945
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_drop.cfg
@@ -0,0 +1 @@
+in Input input.txt
diff --git a/yql/essentials/tests/sql/suites/action/eval_drop.sql b/yql/essentials/tests/sql/suites/action/eval_drop.sql
new file mode 100644
index 0000000000..c5275e2801
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_drop.sql
@@ -0,0 +1,7 @@
+/* syntax version 1 */
+/* postgres can not */
+use plato;
+
+$path = (select min(Path) from folder(""));
+
+drop table $path;
\ No newline at end of file
diff --git a/yql/essentials/tests/sql/suites/action/eval_each_input_table.sql b/yql/essentials/tests/sql/suites/action/eval_each_input_table.sql
new file mode 100644
index 0000000000..45514cb512
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_each_input_table.sql
@@ -0,0 +1,9 @@
+/* postgres can not */
+/* syntax version 1 */
+use plato;
+
+$a = ListMap(ListFromRange(0,2), ($_x)->(CAST(Unicode::ToUpper("i"u) AS String) || "nput"));
+select count(*) FROM each($a view raw);
+
+$a = ListMap(ListFromRange(0,1), ($_x)->(CAST(Unicode::ToUpper("i"u) AS String) || "nput"));
+select count(*) FROM each_strict($a);
diff --git a/yql/essentials/tests/sql/suites/action/eval_ensuretype.sql b/yql/essentials/tests/sql/suites/action/eval_ensuretype.sql
new file mode 100644
index 0000000000..7a21c20868
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_ensuretype.sql
@@ -0,0 +1,3 @@
+/* syntax version 1 */
+/* postgres can not */
+SELECT EnsureType("a", String, CAST(Unicode::ToUpper("me"u) AS String) || "ssage");
diff --git a/yql/essentials/tests/sql/suites/action/eval_extract.sql b/yql/essentials/tests/sql/suites/action/eval_extract.sql
new file mode 100644
index 0000000000..fd9ab0db2e
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_extract.sql
@@ -0,0 +1,4 @@
+/* syntax version 1 */
+/* postgres can not */
+$list = AsList(AsStruct(1 as One, "2" as Two), AsStruct(3 as One, "4" as Two));
+SELECT ListExtract($list, CAST(Unicode::ToUpper("o"u) AS String) || "ne");
diff --git a/yql/essentials/tests/sql/suites/action/eval_filter.cfg b/yql/essentials/tests/sql/suites/action/eval_filter.cfg
new file mode 100644
index 0000000000..c6596e362c
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_filter.cfg
@@ -0,0 +1,2 @@
+in Input input.txt
+udf string_udf
diff --git a/yql/essentials/tests/sql/suites/action/eval_filter.sql b/yql/essentials/tests/sql/suites/action/eval_filter.sql
new file mode 100644
index 0000000000..7fb11ebe59
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_filter.sql
@@ -0,0 +1,12 @@
+/* syntax version 1 */
+/* postgres can not */
+USE plato;
+
+$arg1 = "" || "";
+$arg2 = ($_item)->{return true};
+$arg3 = "" || "";
+$arg4 = "" || "raw";
+
+SELECT
+    count(*)
+FROM FILTER($arg1,$arg2,$arg3,$arg4);
diff --git a/yql/essentials/tests/sql/suites/action/eval_folder.cfg b/yql/essentials/tests/sql/suites/action/eval_folder.cfg
new file mode 100644
index 0000000000..9d0a494107
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_folder.cfg
@@ -0,0 +1 @@
+in Input input_attrs.txt
diff --git a/yql/essentials/tests/sql/suites/action/eval_folder.sql b/yql/essentials/tests/sql/suites/action/eval_folder.sql
new file mode 100644
index 0000000000..fbe663bcac
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_folder.sql
@@ -0,0 +1,5 @@
+/* syntax version 1 */
+/* postgres can not */
+USE plato;
+
+SELECT * FROM Folder(``,"foo;bar");
diff --git a/yql/essentials/tests/sql/suites/action/eval_folder_via_file.cfg b/yql/essentials/tests/sql/suites/action/eval_folder_via_file.cfg
new file mode 100644
index 0000000000..58878f8945
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_folder_via_file.cfg
@@ -0,0 +1 @@
+in Input input.txt
diff --git a/yql/essentials/tests/sql/suites/action/eval_folder_via_file.sql b/yql/essentials/tests/sql/suites/action/eval_folder_via_file.sql
new file mode 100644
index 0000000000..2121ea69c2
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_folder_via_file.sql
@@ -0,0 +1,18 @@
+/* syntax version 1 */
+/* postgres can not */
+use plato;
+
+pragma yt.FolderInlineItemsLimit="0";
+
+$list = (
+    select aggregate_list(Path) from (
+    select Path from folder("")
+    where Type = "table"
+    limit 30
+    )
+);
+
+select 
+    count(*)
+from 
+    each($list)
diff --git a/yql/essentials/tests/sql/suites/action/eval_folder_via_file_in_job.cfg b/yql/essentials/tests/sql/suites/action/eval_folder_via_file_in_job.cfg
new file mode 100644
index 0000000000..289c4251bb
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_folder_via_file_in_job.cfg
@@ -0,0 +1,2 @@
+in Input input.txt
+udf python3_udf
diff --git a/yql/essentials/tests/sql/suites/action/eval_folder_via_file_in_job.sql b/yql/essentials/tests/sql/suites/action/eval_folder_via_file_in_job.sql
new file mode 100644
index 0000000000..10ed2ec09c
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_folder_via_file_in_job.sql
@@ -0,0 +1,25 @@
+/* syntax version 1 */
+/* postgres can not */
+use plato;
+
+pragma yt.FolderInlineItemsLimit="0";
+
+$script = @@
+def f(s):
+  return True
+@@;
+
+$callable = Python3::f(Callable<(String)->Bool>,$script);
+
+$list = (
+    select aggregate_list(Path) from (
+    select Path from folder("")
+    where Type = "table" and $callable(Path)
+    limit 30
+    )
+);
+
+select 
+    count(*)
+from 
+    each($list)
diff --git a/yql/essentials/tests/sql/suites/action/eval_for.sql b/yql/essentials/tests/sql/suites/action/eval_for.sql
new file mode 100644
index 0000000000..71427f2fde
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_for.sql
@@ -0,0 +1,21 @@
+/* syntax version 1 */
+/* postgres can not */
+USE plato;
+
+define action $action1($x) as
+  select $x;
+end define;
+
+$f = ($i)->{
+   return CAST(Unicode::ToUpper(cast($i as Utf8)) AS String);
+};
+
+evaluate for $i in ListMap(ListFromRange(0,3),$f) do $action1($i);
+
+evaluate for $i in ListMap(ListFromRange(0,0),$f) do $action1($i) else do $action1(100);
+
+evaluate for $i in ListMap(ListFromRange(0,0),$f) do $action1($i);
+
+evaluate for $i in Yql::Map(1/1,($x)->{return AsList($x)}) do $action1($i);
+
+evaluate for $i in Yql::Map(1/0,($x)->{return AsList($x)}) do $action1($i);
diff --git a/yql/essentials/tests/sql/suites/action/eval_for_over_subquery.sql b/yql/essentials/tests/sql/suites/action/eval_for_over_subquery.sql
new file mode 100644
index 0000000000..198b80b9a5
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_for_over_subquery.sql
@@ -0,0 +1,13 @@
+/* syntax version 1 */
+/* postgres can not */
+use plato;
+
+$list = (
+    select aggregate_list(key) from Input
+);
+
+define action $echo($x) as
+  select $x;
+end define;
+
+evaluate for $a in $list do $echo($a);
diff --git a/yql/essentials/tests/sql/suites/action/eval_if.sql b/yql/essentials/tests/sql/suites/action/eval_if.sql
new file mode 100644
index 0000000000..f64665fd69
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_if.sql
@@ -0,0 +1,18 @@
+/* syntax version 1 */
+/* postgres can not */
+USE plato;
+
+define action $action1($x) as
+  select $x;
+end define;
+
+evaluate if CAST(Unicode::ToUpper("i"u) AS String) == "I"
+    do $action1(1)
+else
+    do $action1(2);
+
+evaluate if CAST(Unicode::ToUpper("i"u) AS String) != "I"
+    do $action1(3);
+
+evaluate if CAST(Unicode::ToUpper("i"u) AS String) == "I"
+    do $action1(4);
diff --git a/yql/essentials/tests/sql/suites/action/eval_if_guard.sql b/yql/essentials/tests/sql/suites/action/eval_if_guard.sql
new file mode 100644
index 0000000000..4a11e6933e
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_if_guard.sql
@@ -0,0 +1,10 @@
+/* syntax version 1 */
+/* postgres can not */
+use plato;
+
+$list = ListTake(AsList("Input"),0);
+define action $process() as
+    select count(*) FROM each($list);
+end define;
+
+evaluate if ListLength($list)>0 do $process();
diff --git a/yql/essentials/tests/sql/suites/action/eval_input_output_table.cfg b/yql/essentials/tests/sql/suites/action/eval_input_output_table.cfg
new file mode 100644
index 0000000000..386ab9ac7f
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_input_output_table.cfg
@@ -0,0 +1,3 @@
+in Input input.txt
+out Output output.txt
+udf string_udf
diff --git a/yql/essentials/tests/sql/suites/action/eval_input_output_table.sql b/yql/essentials/tests/sql/suites/action/eval_input_output_table.sql
new file mode 100644
index 0000000000..e8bbd374f9
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_input_output_table.sql
@@ -0,0 +1,14 @@
+/* syntax version 1 */
+/* postgres can not */
+USE plato;
+
+$a = CAST(Unicode::ToUpper("o"u) AS String) || "utput";
+$b = CAST(Unicode::ToUpper("i"u) AS String) || "nput";
+INSERT INTO $a
+SELECT
+    key as key,
+    "" as subkey,
+    "value:" || value as value
+FROM $b
+WHERE key < "100"
+ORDER BY key;
diff --git a/yql/essentials/tests/sql/suites/action/eval_input_output_table_subquery.cfg b/yql/essentials/tests/sql/suites/action/eval_input_output_table_subquery.cfg
new file mode 100644
index 0000000000..386ab9ac7f
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_input_output_table_subquery.cfg
@@ -0,0 +1,3 @@
+in Input input.txt
+out Output output.txt
+udf string_udf
diff --git a/yql/essentials/tests/sql/suites/action/eval_input_output_table_subquery.sql b/yql/essentials/tests/sql/suites/action/eval_input_output_table_subquery.sql
new file mode 100644
index 0000000000..429b27f11c
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_input_output_table_subquery.sql
@@ -0,0 +1,16 @@
+/* syntax version 1 */
+/* postgres can not */
+USE plato;
+
+$a = (SELECT CAST(Unicode::ToUpper("o"u) AS String) || "utpu");
+$b = (SELECT CAST(Unicode::ToUpper("i"u) AS String) || "npu");
+$a = $a || CAST(Unicode::ToLower("T"u) AS String);
+$b = $b || CAST(Unicode::ToLower("T"u) AS String);
+INSERT INTO $a
+SELECT
+    key as key,
+    "" as subkey,
+    "value:" || value as value
+FROM $b
+WHERE key < "100"
+ORDER BY key;
diff --git a/yql/essentials/tests/sql/suites/action/eval_like.cfg b/yql/essentials/tests/sql/suites/action/eval_like.cfg
new file mode 100644
index 0000000000..c6596e362c
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_like.cfg
@@ -0,0 +1,2 @@
+in Input input.txt
+udf string_udf
diff --git a/yql/essentials/tests/sql/suites/action/eval_like.sql b/yql/essentials/tests/sql/suites/action/eval_like.sql
new file mode 100644
index 0000000000..24132ebd39
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_like.sql
@@ -0,0 +1,12 @@
+/* syntax version 1 */
+/* postgres can not */
+USE plato;
+
+$arg1 = "" || "";
+$arg2 = CAST(Unicode::ToUpper("i"u) AS String) || "npu_";
+$arg3 = "" || "";
+$arg4 = "" || "raw";
+
+SELECT
+    count(*)
+FROM LIKE($arg1,$arg2,$arg3,$arg4);
diff --git a/yql/essentials/tests/sql/suites/action/eval_on_modif_table_fail.cfg b/yql/essentials/tests/sql/suites/action/eval_on_modif_table_fail.cfg
new file mode 100644
index 0000000000..a26fadcaa7
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_on_modif_table_fail.cfg
@@ -0,0 +1,3 @@
+xfail
+in Input input.txt
+out Output output.txt
diff --git a/yql/essentials/tests/sql/suites/action/eval_on_modif_table_fail.sql b/yql/essentials/tests/sql/suites/action/eval_on_modif_table_fail.sql
new file mode 100644
index 0000000000..67ec4878f3
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_on_modif_table_fail.sql
@@ -0,0 +1,15 @@
+/* syntax version 1 */
+/* postgres can not */
+USE plato;
+
+insert into Output
+select "key" as field
+union all
+select "subkey" as field;
+
+commit;
+
+$whitelist = select aggregate_list(field)
+from Output;
+
+select ForceSpreadMembers([("key", key)],Unwrap($whitelist)) from Input;
diff --git a/yql/essentials/tests/sql/suites/action/eval_percentile.sql b/yql/essentials/tests/sql/suites/action/eval_percentile.sql
new file mode 100644
index 0000000000..64905c1872
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_percentile.sql
@@ -0,0 +1,7 @@
+/* syntax version 1 */
+/* postgres can not */
+$x = 1.0/length(CAST(Unicode::ToUpper("ab"u) AS String));
+select Percentile(key,$x) from (
+select 1 as key
+union all
+select 2 as key)
diff --git a/yql/essentials/tests/sql/suites/action/eval_pragma.cfg b/yql/essentials/tests/sql/suites/action/eval_pragma.cfg
new file mode 100644
index 0000000000..386ab9ac7f
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_pragma.cfg
@@ -0,0 +1,3 @@
+in Input input.txt
+out Output output.txt
+udf string_udf
diff --git a/yql/essentials/tests/sql/suites/action/eval_pragma.sql b/yql/essentials/tests/sql/suites/action/eval_pragma.sql
new file mode 100644
index 0000000000..87f4fb3b4a
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_pragma.sql
@@ -0,0 +1,4 @@
+/* syntax version 1 */
+/* postgres can not */
+$a = "1" || CAST(Unicode::ToUpper("m") AS String);
+pragma yt.DataSizePerJob=$a;
diff --git a/yql/essentials/tests/sql/suites/action/eval_python3_ann.cfg b/yql/essentials/tests/sql/suites/action/eval_python3_ann.cfg
new file mode 100644
index 0000000000..5fee00e994
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_python3_ann.cfg
@@ -0,0 +1 @@
+udf python3_udf
diff --git a/yql/essentials/tests/sql/suites/action/eval_python3_ann.sql b/yql/essentials/tests/sql/suites/action/eval_python3_ann.sql
new file mode 100644
index 0000000000..952c11cbd6
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_python3_ann.sql
@@ -0,0 +1,16 @@
+/* syntax version 1 */
+/* postgres can not */
+$script = @@ 
+from yql.typing import *
+
+def f(x:Int32, y:Int32)->Int32:
+    """
+    a simple sum UDF
+    """
+    return x + y
+@@;
+
+--$f = Python3::f(EvaluateType(ParseTypeHandle(Core::PythonFuncSignature(AsAtom("Python3"), $script, "f"))), $script);
+$f = Python3::f($script);
+
+select $f(1, 2);
diff --git a/yql/essentials/tests/sql/suites/action/eval_python3_signature.cfg b/yql/essentials/tests/sql/suites/action/eval_python3_signature.cfg
new file mode 100644
index 0000000000..5fee00e994
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_python3_signature.cfg
@@ -0,0 +1 @@
+udf python3_udf
diff --git a/yql/essentials/tests/sql/suites/action/eval_python3_signature.sql b/yql/essentials/tests/sql/suites/action/eval_python3_signature.sql
new file mode 100644
index 0000000000..1b3d12a6d5
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_python3_signature.sql
@@ -0,0 +1,17 @@
+/* syntax version 1 */
+/* postgres can not */
+$script = @@ 
+def f(x, y):
+    """
+    (Int32, Int32)
+      ->Int32
+    
+    a simple sum UDF
+    """
+    return x + y
+@@;
+
+--$f = Python3::f(EvaluateType(ParseTypeHandle(Core::PythonFuncSignature(AsAtom("Python3"), $script, "f"))), $script);
+$f = Python3::f($script);
+
+select $f(1, 2);
diff --git a/yql/essentials/tests/sql/suites/action/eval_python_signature.cfg b/yql/essentials/tests/sql/suites/action/eval_python_signature.cfg
new file mode 100644
index 0000000000..a7ca79e497
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_python_signature.cfg
@@ -0,0 +1,2 @@
+udf python2_udf
+providers yt
diff --git a/yql/essentials/tests/sql/suites/action/eval_python_signature.sql b/yql/essentials/tests/sql/suites/action/eval_python_signature.sql
new file mode 100644
index 0000000000..98ccfb12f0
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_python_signature.sql
@@ -0,0 +1,17 @@
+/* syntax version 1 */
+/* postgres can not */
+$script = @@ 
+def f(x, y):
+    """
+    (Int32, Int32)
+      ->Int32
+    
+    a simple sum UDF
+    """
+    return x + y
+@@;
+
+--$f = Python::f(EvaluateType(ParseTypeHandle(Core::PythonFuncSignature(AsAtom("Python"), $script, "f"))), $script);
+$f = Python::f($script);
+
+select $f(1, 2);
diff --git a/yql/essentials/tests/sql/suites/action/eval_range.cfg b/yql/essentials/tests/sql/suites/action/eval_range.cfg
new file mode 100644
index 0000000000..c6596e362c
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_range.cfg
@@ -0,0 +1,2 @@
+in Input input.txt
+udf string_udf
diff --git a/yql/essentials/tests/sql/suites/action/eval_range.sql b/yql/essentials/tests/sql/suites/action/eval_range.sql
new file mode 100644
index 0000000000..9ab6494943
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_range.sql
@@ -0,0 +1,13 @@
+/* syntax version 1 */
+/* postgres can not */
+USE plato;
+
+$arg1 = "" || "";
+$arg2 = CAST(Unicode::ToUpper("i"u) AS String) || "nput";
+$arg3 = CAST(Unicode::ToUpper("i"u) AS String) || "nput";
+$arg4 = "" || "";
+$arg5 = "" || "raw";
+
+SELECT
+    count(*)
+FROM RANGE($arg1,$arg2,$arg3,$arg4,$arg5);
diff --git a/yql/essentials/tests/sql/suites/action/eval_regexp.cfg b/yql/essentials/tests/sql/suites/action/eval_regexp.cfg
new file mode 100644
index 0000000000..c6596e362c
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_regexp.cfg
@@ -0,0 +1,2 @@
+in Input input.txt
+udf string_udf
diff --git a/yql/essentials/tests/sql/suites/action/eval_regexp.sql b/yql/essentials/tests/sql/suites/action/eval_regexp.sql
new file mode 100644
index 0000000000..6e3fcf0ad6
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_regexp.sql
@@ -0,0 +1,11 @@
+/* syntax version 1 */
+/* postgres can not */
+USE plato;
+$arg1 = "" || "";
+$arg2 = (Unicode::ToUpper("i") ?? "") || "npu.";
+$arg3 = "" || "";
+$arg4 = "" || "raw";
+
+SELECT
+    count(*)
+FROM REGEXP($arg1,$arg2,$arg3,$arg4);
diff --git a/yql/essentials/tests/sql/suites/action/eval_resourcetype.sql b/yql/essentials/tests/sql/suites/action/eval_resourcetype.sql
new file mode 100644
index 0000000000..55bb20227f
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_resourcetype.sql
@@ -0,0 +1,3 @@
+/* syntax version 1 */
+/* postgres can not */
+SELECT FormatType(ResourceType(CAST(Unicode::ToUpper("r"u) AS String) || "es"));
diff --git a/yql/essentials/tests/sql/suites/action/eval_result_label.cfg b/yql/essentials/tests/sql/suites/action/eval_result_label.cfg
new file mode 100644
index 0000000000..5c248bff3d
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_result_label.cfg
@@ -0,0 +1 @@
+udf string_udf
diff --git a/yql/essentials/tests/sql/suites/action/eval_result_label.sql b/yql/essentials/tests/sql/suites/action/eval_result_label.sql
new file mode 100644
index 0000000000..1f9e67d195
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_result_label.sql
@@ -0,0 +1,4 @@
+/* syntax version 1 */
+/* postgres can not */
+$x = CAST(Unicode::ToUpper("foo"u) AS String);
+select 1 into result $x;
diff --git a/yql/essentials/tests/sql/suites/action/eval_sample.cfg b/yql/essentials/tests/sql/suites/action/eval_sample.cfg
new file mode 100644
index 0000000000..a654f9117d
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_sample.cfg
@@ -0,0 +1 @@
+in Input input1.txt
diff --git a/yql/essentials/tests/sql/suites/action/eval_sample.sql b/yql/essentials/tests/sql/suites/action/eval_sample.sql
new file mode 100644
index 0000000000..3b84c6e5c1
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_sample.sql
@@ -0,0 +1,7 @@
+/* syntax version 1 */
+/* postgres can not */
+/* custom check: len(yt_res_yson[0]['Write'][0]['Data']) < 10 */
+$x = 1.0 / 3;
+SELECT *
+FROM plato.Input
+SAMPLE $x;
\ No newline at end of file
diff --git a/yql/essentials/tests/sql/suites/action/eval_skip_take.cfg b/yql/essentials/tests/sql/suites/action/eval_skip_take.cfg
new file mode 100644
index 0000000000..c6596e362c
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_skip_take.cfg
@@ -0,0 +1,2 @@
+in Input input.txt
+udf string_udf
diff --git a/yql/essentials/tests/sql/suites/action/eval_skip_take.sql b/yql/essentials/tests/sql/suites/action/eval_skip_take.sql
new file mode 100644
index 0000000000..06d56e5b25
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_skip_take.sql
@@ -0,0 +1,8 @@
+/* syntax version 1 */
+/* postgres can not */
+use plato;
+
+select * from Input
+order by key
+limit length(CAST(Unicode::ToUpper("a"u) AS String))
+offset length(CAST(Unicode::ToUpper("bc"u) AS String));
diff --git a/yql/essentials/tests/sql/suites/action/eval_table_with_view.sql b/yql/essentials/tests/sql/suites/action/eval_table_with_view.sql
new file mode 100644
index 0000000000..2c27b55d58
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_table_with_view.sql
@@ -0,0 +1,6 @@
+/* syntax version 1 */
+/* postgres can not */
+USE plato;
+$x = "Input";
+SELECT *
+FROM $x VIEW raw LIMIT 1;
\ No newline at end of file
diff --git a/yql/essentials/tests/sql/suites/action/eval_taggedtype.sql b/yql/essentials/tests/sql/suites/action/eval_taggedtype.sql
new file mode 100644
index 0000000000..f84bd85c8d
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_taggedtype.sql
@@ -0,0 +1,3 @@
+/* syntax version 1 */
+/* postgres can not */
+SELECT FormatType(TaggedType(DataType("Int32"), CAST(Unicode::ToUpper("r"u) AS String) || "es"));
diff --git a/yql/essentials/tests/sql/suites/action/eval_type.sql b/yql/essentials/tests/sql/suites/action/eval_type.sql
new file mode 100644
index 0000000000..397798867f
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_type.sql
@@ -0,0 +1,3 @@
+/* syntax version 1 */
+/* postgres can not */
+select FormatType(EvaluateType(ParseTypeHandle("Int32" || "?")));
diff --git a/yql/essentials/tests/sql/suites/action/eval_typeof_output_table.cfg b/yql/essentials/tests/sql/suites/action/eval_typeof_output_table.cfg
new file mode 100644
index 0000000000..1d0f17aef1
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_typeof_output_table.cfg
@@ -0,0 +1,3 @@
+in Input input.txt
+out Output output.txt
+xfail
diff --git a/yql/essentials/tests/sql/suites/action/eval_typeof_output_table.sql b/yql/essentials/tests/sql/suites/action/eval_typeof_output_table.sql
new file mode 100644
index 0000000000..88b43b3736
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_typeof_output_table.sql
@@ -0,0 +1,25 @@
+/* syntax version 1 */
+/* postgres can not */
+USE plato;
+
+INSERT INTO Output
+SELECT
+    key || "foo" as key2
+FROM Input;
+
+COMMIT;
+
+$input = PROCESS Output;
+$c = EvaluateCode(ReprCode(FormatType(TypeOf($input))));
+select $c;
+
+INSERT INTO Output WITH TRUNCATE
+SELECT
+    key || "foo" as key3
+FROM Input;
+
+COMMIT;
+
+$input = PROCESS Output;
+$c = EvaluateCode(ReprCode(FormatType(TypeOf($input))));
+select $c;
diff --git a/yql/essentials/tests/sql/suites/action/eval_unresolved_type_arg.sql b/yql/essentials/tests/sql/suites/action/eval_unresolved_type_arg.sql
new file mode 100644
index 0000000000..1ebfe07d30
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_unresolved_type_arg.sql
@@ -0,0 +1,25 @@
+/* syntax version 1 */
+/* postgres can not */
+USE plato;
+
+$myAddSuffix = ($row, $value) -> {
+    $type = TypeOf($row);
+    --$type=Struct<key:String,subkey:String,value:String>;
+    $lambda = EvaluateCode(LambdaCode(($r)->{
+        return FuncCode("AsStruct",
+            ListMap(StructTypeComponents(TypeHandle($type)),
+                ($i)->{ return ListCode(
+                    AtomCode($i.Name),
+                    FuncCode("Concat",
+                        FuncCode("Member",$r,AtomCode($i.Name)),
+                        ReprCode($value)
+                    )) }));
+        
+    }));
+    
+    return $lambda($row);
+};
+
+SELECT
+    $myAddSuffix(TableRow(), "*")
+FROM Input;
diff --git a/yql/essentials/tests/sql/suites/action/eval_values_output_table_subquery.cfg b/yql/essentials/tests/sql/suites/action/eval_values_output_table_subquery.cfg
new file mode 100644
index 0000000000..386ab9ac7f
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_values_output_table_subquery.cfg
@@ -0,0 +1,3 @@
+in Input input.txt
+out Output output.txt
+udf string_udf
diff --git a/yql/essentials/tests/sql/suites/action/eval_values_output_table_subquery.sql b/yql/essentials/tests/sql/suites/action/eval_values_output_table_subquery.sql
new file mode 100644
index 0000000000..240f4d2263
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_values_output_table_subquery.sql
@@ -0,0 +1,8 @@
+/* syntax version 1 */
+/* postgres can not */
+USE plato;
+
+$a = (SELECT CAST(Unicode::ToUpper("o"u) AS String) || "utpu");
+$a = $a || CAST(Unicode::ToLower("T"u) AS String);
+INSERT INTO $a (key, subkey, value)
+VALUES (1, "foo", false);
diff --git a/yql/essentials/tests/sql/suites/action/eval_variant.sql b/yql/essentials/tests/sql/suites/action/eval_variant.sql
new file mode 100644
index 0000000000..e4555ffd6f
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/eval_variant.sql
@@ -0,0 +1,4 @@
+/* syntax version 1 */
+/* postgres can not */
+$vt = ParseType("Variant<One:Int32,Two:String>");
+SELECT Variant(12, CAST(Unicode::ToUpper("o"u) AS String) || "ne", $vt);
diff --git a/yql/essentials/tests/sql/suites/action/evaluate_match_type.sql b/yql/essentials/tests/sql/suites/action/evaluate_match_type.sql
new file mode 100644
index 0000000000..bca34d037a
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/evaluate_match_type.sql
@@ -0,0 +1,12 @@
+/* syntax version 1 */
+/* postgres can not */
+use plato;
+
+$keep_only_last = ($row) -> {
+    $members = ListFilter(StructMembers($row), ($x) -> (FIND($x, "key") IS NOT NULL));
+    return ChooseMembers($row, $members)
+};
+
+
+select * from 
+(select $keep_only_last(TableRow()) from Input)
\ No newline at end of file
diff --git a/yql/essentials/tests/sql/suites/action/evaluate_pure.cfg b/yql/essentials/tests/sql/suites/action/evaluate_pure.cfg
new file mode 100644
index 0000000000..72eff595f4
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/evaluate_pure.cfg
@@ -0,0 +1,2 @@
+in Input input.txt
+udf datetime_udf
diff --git a/yql/essentials/tests/sql/suites/action/evaluate_pure.sql b/yql/essentials/tests/sql/suites/action/evaluate_pure.sql
new file mode 100644
index 0000000000..b89afe26bc
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/evaluate_pure.sql
@@ -0,0 +1,13 @@
+/* syntax version 1 */
+/* postgres can not */
+USE plato;
+
+select EvaluateExpr(YQL::RandomNumber()), YQL::RandomNumber();
+select key, EvaluateExpr(cast(CurrentUtcDate() as string)) as `date` from Input;
+select YQL::String(EvaluateAtom("foo" || "bar"));
+select EvaluateExpr(CurrentUtcTimestamp()), CurrentUtcTimestamp();
+$y = Yson("{a=7u;c=[<d=%true>1;#;\"привет\";-3.4]}");
+select Yson::Equals(EvaluateExpr($y), $y);
+select EvaluateExpr(TzDate("2000-01-01,Europe/Moscow"));
+select EvaluateExpr(TzDatetime("2000-01-01T01:02:03,Europe/Moscow"));
+select EvaluateExpr(TzTimestamp("2000-01-01T01:02:03.456789,Europe/Moscow"));
diff --git a/yql/essentials/tests/sql/suites/action/evaluate_queries.cfg b/yql/essentials/tests/sql/suites/action/evaluate_queries.cfg
new file mode 100644
index 0000000000..ad52c79527
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/evaluate_queries.cfg
@@ -0,0 +1,2 @@
+in Input input.txt
+out Output output.txt
diff --git a/yql/essentials/tests/sql/suites/action/evaluate_queries.sql b/yql/essentials/tests/sql/suites/action/evaluate_queries.sql
new file mode 100644
index 0000000000..8671f14def
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/evaluate_queries.sql
@@ -0,0 +1,28 @@
+/* syntax version 1 */
+/* postgres can not */
+USE plato;
+
+$s = (select count(*) from Input);
+select EvaluateExpr($s);
+/*
+$s = (select key from Input);
+select EvaluateExpr($s);
+
+$s = (select key || "foo" from Input);
+select EvaluateExpr($s);
+
+$s = (select aggregate_list(key) from Input);
+select EvaluateExpr($s);
+
+$s = (select v from (select key,min(value) as v from Input group by key order by key limit 1));
+select EvaluateExpr($s);
+
+$s = (select key from Input order by key limit 1);
+select EvaluateExpr($s);
+
+$s = (select lag(key) over w from Input window w as ());
+select EvaluateExpr($s);
+
+$s = (select a.key from Input as a join Input as b using(key));
+select EvaluateExpr($s);
+*/
diff --git a/yql/essentials/tests/sql/suites/action/export_action.cfg b/yql/essentials/tests/sql/suites/action/export_action.cfg
new file mode 100644
index 0000000000..d8349c7037
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/export_action.cfg
@@ -0,0 +1,2 @@
+in Input input.txt
+file lib1.sql lib1.sql.txt
diff --git a/yql/essentials/tests/sql/suites/action/export_action.sql b/yql/essentials/tests/sql/suites/action/export_action.sql
new file mode 100644
index 0000000000..59ecc86d5b
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/export_action.sql
@@ -0,0 +1,6 @@
+/* syntax version 1 */
+/* postgres can not */
+/* kikimr can not - range not supported */
+pragma library("lib1.sql");
+import lib1 symbols $action;
+do $action("Input");
diff --git a/yql/essentials/tests/sql/suites/action/inline_action.sql b/yql/essentials/tests/sql/suites/action/inline_action.sql
new file mode 100644
index 0000000000..44586e32e3
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/inline_action.sql
@@ -0,0 +1,16 @@
+/* syntax version 1 */
+/* postgres can not */
+do begin 
+    select 1;
+end do;
+
+evaluate if true do begin
+    select 1;
+end do
+else do begin
+    select 2;
+end do;
+
+evaluate for $i in AsList(1,2,3) do begin
+    select $i;
+end do;
diff --git a/yql/essentials/tests/sql/suites/action/input.txt b/yql/essentials/tests/sql/suites/action/input.txt
new file mode 100644
index 0000000000..65949ea745
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/input.txt
@@ -0,0 +1,4 @@
+{"key"="075";"subkey"="1";"value"="abc"};
+{"key"="800";"subkey"="2";"value"="ddd"};
+{"key"="020";"subkey"="3";"value"="q"};
+{"key"="150";"subkey"="4";"value"="qzz"};
diff --git a/yql/essentials/tests/sql/suites/action/input1.txt b/yql/essentials/tests/sql/suites/action/input1.txt
new file mode 100644
index 0000000000..9e2c7c8718
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/input1.txt
@@ -0,0 +1,10 @@
+{"key"="023";"subkey"="3";"value"="aaa"};
+{"key"="037";"subkey"="5";"value"="ddd"};
+{"key"="075";"subkey"="1";"value"="abc"};
+{"key"="150";"subkey"="1";"value"="aaa"};
+{"key"="160";"subkey"="3";"value"="iii"};
+{"key"="170";"subkey"="8";"value"="zzz"};
+{"key"="200";"subkey"="7";"value"="qqq"};
+{"key"="527";"subkey"="4";"value"="bbb"};
+{"key"="761";"subkey"="6";"value"="ccc"};
+{"key"="911";"subkey"="2";"value"="kkk"};
diff --git a/yql/essentials/tests/sql/suites/action/input_attrs.txt b/yql/essentials/tests/sql/suites/action/input_attrs.txt
new file mode 100644
index 0000000000..65949ea745
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/input_attrs.txt
@@ -0,0 +1,4 @@
+{"key"="075";"subkey"="1";"value"="abc"};
+{"key"="800";"subkey"="2";"value"="ddd"};
+{"key"="020";"subkey"="3";"value"="q"};
+{"key"="150";"subkey"="4";"value"="qzz"};
diff --git a/yql/essentials/tests/sql/suites/action/input_attrs.txt.attr b/yql/essentials/tests/sql/suites/action/input_attrs.txt.attr
new file mode 100644
index 0000000000..d2659911d1
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/input_attrs.txt.attr
@@ -0,0 +1,32 @@
+{
+    "_yql_row_spec" = {
+        "Type" = [
+            "StructType";
+            [
+                [
+                    "key";
+                    [
+                        "DataType";
+                        "String"
+                    ]
+                ];
+                [
+                    "subkey";
+                    [
+                        "DataType";
+                        "String"
+                    ]
+                ];
+                [
+                    "value";
+                    [
+                        "DataType";
+                        "String"
+                    ]
+                ]
+            ]
+        ]
+    };
+    "foo" = 1;
+    "bar" = "text";
+}
diff --git a/yql/essentials/tests/sql/suites/action/insert_after_eval.cfg b/yql/essentials/tests/sql/suites/action/insert_after_eval.cfg
new file mode 100644
index 0000000000..b1f9d81471
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/insert_after_eval.cfg
@@ -0,0 +1 @@
+out Output modify.txt
diff --git a/yql/essentials/tests/sql/suites/action/insert_after_eval.sql b/yql/essentials/tests/sql/suites/action/insert_after_eval.sql
new file mode 100644
index 0000000000..60ab74c109
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/insert_after_eval.sql
@@ -0,0 +1,9 @@
+/* syntax version 1 */
+/* postgres can not */
+/* multirun can not */
+USE plato;
+
+$s1 = (select count(*) from Output);
+$s2 = (select max(key) from Output);
+insert into Output with truncate
+select EvaluateExpr($s1) as a, EvaluateExpr($s2) as b;
diff --git a/yql/essentials/tests/sql/suites/action/insert_after_eval_xlock.cfg b/yql/essentials/tests/sql/suites/action/insert_after_eval_xlock.cfg
new file mode 100644
index 0000000000..b1f9d81471
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/insert_after_eval_xlock.cfg
@@ -0,0 +1 @@
+out Output modify.txt
diff --git a/yql/essentials/tests/sql/suites/action/insert_after_eval_xlock.sql b/yql/essentials/tests/sql/suites/action/insert_after_eval_xlock.sql
new file mode 100644
index 0000000000..c31b9e04eb
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/insert_after_eval_xlock.sql
@@ -0,0 +1,9 @@
+/* syntax version 1 */
+/* postgres can not */
+/* multirun can not */
+USE plato;
+
+$s1 = (select count(*) from Output with xlock);
+$s2 = (select max(key) from Output with xlock);
+insert into Output with truncate
+select EvaluateExpr($s1) as a, EvaluateExpr($s2) as b;
diff --git a/yql/essentials/tests/sql/suites/action/insert_each_from_folder.cfg b/yql/essentials/tests/sql/suites/action/insert_each_from_folder.cfg
new file mode 100644
index 0000000000..ad52c79527
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/insert_each_from_folder.cfg
@@ -0,0 +1,2 @@
+in Input input.txt
+out Output output.txt
diff --git a/yql/essentials/tests/sql/suites/action/insert_each_from_folder.sql b/yql/essentials/tests/sql/suites/action/insert_each_from_folder.sql
new file mode 100644
index 0000000000..dc06200679
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/insert_each_from_folder.sql
@@ -0,0 +1,19 @@
+/* syntax version 1 */
+/* postgres can not */
+/* multirun can not */
+use plato;
+
+$list = (
+    select aggregate_list(Path) from (
+    select Path from folder("")
+    where Type = "table" and Path like "Input%"
+    order by Path desc
+    limit 30
+    )
+);
+
+insert into Output with truncate
+select 
+    count(*)
+from 
+    each($list)
diff --git a/yql/essentials/tests/sql/suites/action/lambda_arg_count.sql b/yql/essentials/tests/sql/suites/action/lambda_arg_count.sql
new file mode 100644
index 0000000000..37854ea7b8
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/lambda_arg_count.sql
@@ -0,0 +1,14 @@
+/* syntax version 1 */
+/* postgres can not */
+SELECT
+   LambdaArgumentsCount(()->(1)),
+   LambdaArgumentsCount(($x)->($x+1)),
+   LambdaArgumentsCount(($x, $y)->($x+$y)),
+   LambdaArgumentsCount(($x?)->($x+1)),
+   LambdaArgumentsCount(($x, $y?)->($x+$y)),
+
+   LambdaOptionalArgumentsCount(()->(1)),
+   LambdaOptionalArgumentsCount(($x)->($x+1)),
+   LambdaOptionalArgumentsCount(($x, $y)->($x+$y)),
+   LambdaOptionalArgumentsCount(($x?)->($x+1)),
+   LambdaOptionalArgumentsCount(($x, $y?)->($x+$y));
diff --git a/yql/essentials/tests/sql/suites/action/large_evaluate_for_fail.cfg b/yql/essentials/tests/sql/suites/action/large_evaluate_for_fail.cfg
new file mode 100644
index 0000000000..5dae597903
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/large_evaluate_for_fail.cfg
@@ -0,0 +1 @@
+xfail
diff --git a/yql/essentials/tests/sql/suites/action/large_evaluate_for_fail.sql b/yql/essentials/tests/sql/suites/action/large_evaluate_for_fail.sql
new file mode 100644
index 0000000000..74a9ac9790
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/large_evaluate_for_fail.sql
@@ -0,0 +1,5 @@
+/* syntax version 1 */
+/* postgres can not */
+pragma config.flags("EvaluateForLimit", "3");
+
+evaluate for $_i in ListFromRange(0, 10) do empty_action();
diff --git a/yql/essentials/tests/sql/suites/action/lib1.sql.txt b/yql/essentials/tests/sql/suites/action/lib1.sql.txt
new file mode 100644
index 0000000000..78edb4e064
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/lib1.sql.txt
@@ -0,0 +1,7 @@
+use plato;
+
+define action $action($table) as
+  select key,count(*) as cnt from $table group by key order by key;
+end define;
+
+export $action;
diff --git a/yql/essentials/tests/sql/suites/action/mixed_eval_typeof_world1.cfg b/yql/essentials/tests/sql/suites/action/mixed_eval_typeof_world1.cfg
new file mode 100644
index 0000000000..dbda958ebd
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/mixed_eval_typeof_world1.cfg
@@ -0,0 +1,6 @@
+xfail
+in Input input.txt
+out Output1 output1.txt
+out Output2 output2.txt
+out Output3 output3.txt
+
diff --git a/yql/essentials/tests/sql/suites/action/mixed_eval_typeof_world1.sql b/yql/essentials/tests/sql/suites/action/mixed_eval_typeof_world1.sql
new file mode 100644
index 0000000000..54de5b2950
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/mixed_eval_typeof_world1.sql
@@ -0,0 +1,45 @@
+/* syntax version 1 */
+/* postgres can not */
+use plato;
+
+$force_remove_members = ($struct, $to_remove) -> {
+    $remover = EvaluateCode(LambdaCode(($st) -> {
+        $to_keep = ListFlatMap(StructTypeComponents(TypeHandle(TypeOf($struct))), ($x) -> {return IF($x.Name not in $to_remove, $x.Name)});
+        return FuncCode(
+            "AsStruct",
+            ListMap(
+                $to_keep,
+                ($x) -> {return ListCode(AtomCode($x), FuncCode("Member", $st, AtomCode($x)))}
+            )
+        )
+    }));
+    return $remover($struct)
+};
+
+define action $func($input, $output) as
+    $jname = $output;
+    insert into @$jname
+    with truncate
+        select
+            *
+        from $input as input;
+    commit;
+    insert into $output
+        with truncate
+    select
+        AGG_LIST(
+            $force_remove_members(
+                TableRow(),
+                ['']
+            )
+        )
+    from @$jname;
+    commit;
+end define;
+
+$exps = [('Input','Output1'),('Input','Output2'),('Input','Output3')];
+evaluate for $exp_name in $exps do begin
+    $input = $exp_name.0;
+    $output = $exp_name.1;
+    do $func($input, $output);
+end do;
diff --git a/yql/essentials/tests/sql/suites/action/modify.txt b/yql/essentials/tests/sql/suites/action/modify.txt
new file mode 100644
index 0000000000..15f63a38a7
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/modify.txt
@@ -0,0 +1,2 @@
+{"key"="023";"subkey"="3";"value"="aaa"};
+{"key"="037";"subkey"="5";"value"="ddd"};
diff --git a/yql/essentials/tests/sql/suites/action/modify.txt.attr b/yql/essentials/tests/sql/suites/action/modify.txt.attr
new file mode 100644
index 0000000000..36b3c00c90
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/modify.txt.attr
@@ -0,0 +1,5 @@
+{
+    "_yql_row_spec"={
+       "Type"=["StructType";[["key";["DataType";"String";];];["subkey";["DataType";"String";];];["value";["DataType";"String";];];];];
+    }
+}
diff --git a/yql/essentials/tests/sql/suites/action/nested_action.sql b/yql/essentials/tests/sql/suites/action/nested_action.sql
new file mode 100644
index 0000000000..4beb520d5a
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/nested_action.sql
@@ -0,0 +1,14 @@
+/* syntax version 1 */
+/* postgres can not */
+define action $action($b,$c) as
+    define action $aaa() as
+        select $b;
+    end define;
+    define action $bbb() as
+        select $c;
+    end define;    
+    do $aaa();
+    do $bbb();
+end define;
+
+do $action(1,2);
diff --git a/yql/essentials/tests/sql/suites/action/nested_eval.sql b/yql/essentials/tests/sql/suites/action/nested_eval.sql
new file mode 100644
index 0000000000..0960c6da74
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/nested_eval.sql
@@ -0,0 +1,25 @@
+/* syntax version 1 */
+/* postgres can not */
+$make_struct = Callable(
+    Callable<(String) -> Struct<lel : Int32>>,
+    ($_string) -> { return AsStruct(5 as lel); }
+);
+
+$kekify_struct = ($struct) -> {
+    return EvaluateCode(FuncCode("AsStruct",
+        ListMap(
+            StructTypeComponents(TypeHandle(TypeOf($struct))),
+            ($_component) -> { return ListCode(AtomCode("kek"), ReprCode(42)); }
+        )
+    ));
+};
+
+$struct = AsStruct(
+    Callable(
+        Callable<(String)->Struct<kek : Int32>>,
+        ($string) -> { return $kekify_struct($make_struct($string)); }
+    ) as KekFromString,
+    TypeHandle(Int32) as IntHandle
+);
+
+select FormatType(EvaluateType($struct.IntHandle));
diff --git a/yql/essentials/tests/sql/suites/action/nested_rewrite_io.sql b/yql/essentials/tests/sql/suites/action/nested_rewrite_io.sql
new file mode 100644
index 0000000000..4150bc7e3f
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/nested_rewrite_io.sql
@@ -0,0 +1,22 @@
+use plato;
+$input = select * from AS_TABLE([<|a:"foo",b:"123"|>]);
+
+$mapping = select {"a":"String", "b":"Int32"} from Input limit 1;
+
+$transformer = ($type)->{
+    $t = EvaluateType(ParseTypeHandle($type));
+    return ($value)->{ return cast($value as $t); };
+};
+
+$converter = ($row)->{
+   return EvaluateCode(LambdaCode(($rowCode)->{
+       return FuncCode("AsStruct", ListMap(StructMembers($row), ($name)->{
+           return ListCode(
+               AtomCode($name),
+               FuncCode("Apply", QuoteCode($transformer(Unwrap($mapping[$name]))), FuncCode("Member", $rowCode, AtomCode($name)))
+           );
+       }));
+   }))($row);
+};
+
+select * from (select $converter(TableRow()) from $input) flatten columns;
diff --git a/yql/essentials/tests/sql/suites/action/nested_subquery.cfg b/yql/essentials/tests/sql/suites/action/nested_subquery.cfg
new file mode 100644
index 0000000000..386ab9ac7f
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/nested_subquery.cfg
@@ -0,0 +1,3 @@
+in Input input.txt
+out Output output.txt
+udf string_udf
diff --git a/yql/essentials/tests/sql/suites/action/nested_subquery.sql b/yql/essentials/tests/sql/suites/action/nested_subquery.sql
new file mode 100644
index 0000000000..375dee1116
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/nested_subquery.sql
@@ -0,0 +1,13 @@
+/* syntax version 1 */
+/* postgres can not */
+use plato;
+
+define subquery $q($name) as
+    define subquery $nested() as
+        select $name;
+    end define;
+
+    process $nested();
+end define;
+
+process $q(CAST(Unicode::ToUpper("foo"u) AS String));
diff --git a/yql/essentials/tests/sql/suites/action/no_columns_in_do.sqlx b/yql/essentials/tests/sql/suites/action/no_columns_in_do.sqlx
new file mode 100644
index 0000000000..b51e642f16
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/no_columns_in_do.sqlx
@@ -0,0 +1,8 @@
+/* postgres can not */
+$a = `aaa`;
+
+define action $action($s) as
+  select $s;
+end define;
+
+do $action($a);
diff --git a/yql/essentials/tests/sql/suites/action/parallel_for.sql b/yql/essentials/tests/sql/suites/action/parallel_for.sql
new file mode 100644
index 0000000000..d9bfcfcedb
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/parallel_for.sql
@@ -0,0 +1,11 @@
+/* yt can not */
+use plato;
+
+evaluate parallel for $i in [1,2,1,2,1] do begin
+insert into Output
+select $i as a;
+end do;
+
+commit;
+insert into Output with truncate
+select a from Output order by a;
diff --git a/yql/essentials/tests/sql/suites/action/parallel_for_commit.sqlx b/yql/essentials/tests/sql/suites/action/parallel_for_commit.sqlx
new file mode 100644
index 0000000000..44ea0ff126
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/parallel_for_commit.sqlx
@@ -0,0 +1,4 @@
+evaluate parallel for $i in [1,2,3] do begin
+commit;
+end do;
+
diff --git a/yql/essentials/tests/sql/suites/action/parallel_for_select.sqlx b/yql/essentials/tests/sql/suites/action/parallel_for_select.sqlx
new file mode 100644
index 0000000000..4b190b2c56
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/parallel_for_select.sqlx
@@ -0,0 +1,4 @@
+evaluate parallel for $i in [1,2,3] do begin
+select $i;
+end do;
+
diff --git a/yql/essentials/tests/sql/suites/action/parallel_for_values.sqlx b/yql/essentials/tests/sql/suites/action/parallel_for_values.sqlx
new file mode 100644
index 0000000000..80891830a9
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/parallel_for_values.sqlx
@@ -0,0 +1,4 @@
+evaluate parallel for $i in [1,2,3] do begin
+values ($i);
+end do;
+
diff --git a/yql/essentials/tests/sql/suites/action/pass_action_as_param.sql b/yql/essentials/tests/sql/suites/action/pass_action_as_param.sql
new file mode 100644
index 0000000000..e5ab80b264
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/pass_action_as_param.sql
@@ -0,0 +1,14 @@
+/* syntax version 1 */
+/* postgres can not */
+define action $dup($x) as
+   do $x();
+   do $x();
+end define;
+
+do $dup(empty_action);
+
+define action $sel_foo() as
+   select "foo";
+end define;
+
+do $dup($sel_foo);
diff --git a/yql/essentials/tests/sql/suites/action/pass_subquery_as_param.sql b/yql/essentials/tests/sql/suites/action/pass_subquery_as_param.sql
new file mode 100644
index 0000000000..23e1af9551
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/pass_subquery_as_param.sql
@@ -0,0 +1,13 @@
+/* syntax version 1 */
+/* postgres can not */
+define subquery $dup($x) as
+   select * from $x(1)
+   union all
+   select * from $x(2);
+end define;
+
+define subquery $sub($n) as
+   select $n * 10;
+end define;
+           
+select * from $dup($sub);
diff --git a/yql/essentials/tests/sql/suites/action/pending_arg_fail.cfg b/yql/essentials/tests/sql/suites/action/pending_arg_fail.cfg
new file mode 100644
index 0000000000..eb2e5315d1
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/pending_arg_fail.cfg
@@ -0,0 +1 @@
+xfail
\ No newline at end of file
diff --git a/yql/essentials/tests/sql/suites/action/pending_arg_fail.sql b/yql/essentials/tests/sql/suites/action/pending_arg_fail.sql
new file mode 100644
index 0000000000..5c09ceb11c
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/pending_arg_fail.sql
@@ -0,0 +1,4 @@
+/* syntax version 1 */
+/* postgres can not */
+use plato;
+select ListExtract(value,key) from Input;
\ No newline at end of file
diff --git a/yql/essentials/tests/sql/suites/action/process_from_subquery_with_orderby.sql b/yql/essentials/tests/sql/suites/action/process_from_subquery_with_orderby.sql
new file mode 100644
index 0000000000..24ad5b76f9
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/process_from_subquery_with_orderby.sql
@@ -0,0 +1,5 @@
+/* postgres can not */
+define subquery $src() as
+  select * from plato.Input order by key;
+end define;
+process $src();
diff --git a/yql/essentials/tests/sql/suites/action/runtime_apply_quoted_code.sql b/yql/essentials/tests/sql/suites/action/runtime_apply_quoted_code.sql
new file mode 100644
index 0000000000..8a4a92b353
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/runtime_apply_quoted_code.sql
@@ -0,0 +1,21 @@
+/* syntax version 1 */
+/* postgres can not */
+$func = ($x)->{
+    return $x == 1;
+};
+
+$structApply = ($strValue, $f)->{
+    $code = EvaluateCode(LambdaCode(($strCode)->{
+        $members = StructTypeComponents(TypeHandle(TypeOf($strValue)));
+       
+        return Yql::Fold($members, ReprCode(false), ($item, $state)->{
+            $member = FuncCode("Member", $strCode, AtomCode($item.Name));
+            $apply = FuncCode("Apply", QuoteCode($f), $member);
+            return FuncCode("Or", $state, $apply);
+        });
+    }));
+    return $code($strValue);
+};
+
+select $structApply(AsStruct(1 as a,2 as b,3 as c), $func);
+select $structApply(AsStruct(4 as a,2 as b,3 as c), $func);
diff --git a/yql/essentials/tests/sql/suites/action/runtime_for_select.sql b/yql/essentials/tests/sql/suites/action/runtime_for_select.sql
new file mode 100644
index 0000000000..5e9ad5d10f
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/runtime_for_select.sql
@@ -0,0 +1,44 @@
+/* syntax version 1 */
+/* postgres can not */
+for $i in Just(AsList(1,2,3)) do begin 
+    select $i;
+end do
+else do begin
+    select 10;
+end do;
+
+for $i in Just(ListCreate(Int32)) do begin 
+    select $i;
+end do
+else do begin
+    select 11;
+end do;
+
+for $i in null do begin 
+    select $i;
+end do
+else do begin
+    select 12;
+end do;
+
+for $i in AsList(4) do begin 
+    select $i;
+end do
+else do begin
+    select 13;
+end do;
+
+for $i in ListCreate(String) do begin 
+    select $i;
+end do
+else do begin
+    select 14;
+end do;
+
+for $i in AsList(5) do begin 
+    select $i;
+end do;
+
+for $i in ListCreate(Bool) do begin 
+    select $i;
+end do
diff --git a/yql/essentials/tests/sql/suites/action/runtime_format_free_args_code.sql b/yql/essentials/tests/sql/suites/action/runtime_format_free_args_code.sql
new file mode 100644
index 0000000000..4d037fc4ca
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/runtime_format_free_args_code.sql
@@ -0,0 +1,6 @@
+$x = EvaluateCode(LambdaCode(($arg1, $arg2)->{
+    $f = FuncCode("Concat", $arg1, $arg2);
+    return ReprCode(FormatCode($f));
+}));
+
+select $x(1,2);
diff --git a/yql/essentials/tests/sql/suites/action/runtime_format_type.sql b/yql/essentials/tests/sql/suites/action/runtime_format_type.sql
new file mode 100644
index 0000000000..d08b6faf40
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/runtime_format_type.sql
@@ -0,0 +1,3 @@
+/* syntax version 1 */
+/* postgres can not */
+select FormatType(TypeHandle(TypeOf(1)));
diff --git a/yql/essentials/tests/sql/suites/action/runtime_if_select.sql b/yql/essentials/tests/sql/suites/action/runtime_if_select.sql
new file mode 100644
index 0000000000..c81f207ae9
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/runtime_if_select.sql
@@ -0,0 +1,29 @@
+/* syntax version 1 */
+/* postgres can not */
+use plato;
+
+insert into @foo
+select count(*) as count from Input;
+commit;
+$n = (select count from @foo);
+$predicate = $n > 1;
+
+if $predicate do begin
+    select 1;
+end do;
+
+if not $predicate do begin
+    select 2;
+end do;
+
+if $predicate do begin
+    select 3;
+end do else do begin
+    select 4;
+end do;
+
+if not $predicate do begin
+    select 5;
+end do else do begin
+    select 6;
+end do;
diff --git a/yql/essentials/tests/sql/suites/action/runtime_make_code.sql b/yql/essentials/tests/sql/suites/action/runtime_make_code.sql
new file mode 100644
index 0000000000..c340ce6fda
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/runtime_make_code.sql
@@ -0,0 +1,15 @@
+/* postgres can not */
+/* syntax version 1 */
+select FormatCode(
+    ListCode(
+        AtomCode("1"),
+        AsList(AtomCode("2"),AtomCode("3")),
+        FuncCode("Func",
+            AtomCode("4"),
+            AsList(AtomCode("5"),AtomCode("6"))),
+        LambdaCode(()->{ return AtomCode("7") }),
+        LambdaCode(($x)->{ return FuncCode("-",$x) }),
+        LambdaCode(($x,$y)->{ return FuncCode("*",$x,$y) }),
+        LambdaCode(2, ($args)->{ return FuncCode("+",Unwrap($args[0]),Unwrap($args[1])) }),
+    )
+);
diff --git a/yql/essentials/tests/sql/suites/action/runtime_parse_type.sql b/yql/essentials/tests/sql/suites/action/runtime_parse_type.sql
new file mode 100644
index 0000000000..a6396ecbbd
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/runtime_parse_type.sql
@@ -0,0 +1,3 @@
+/* postgres can not */
+/* syntax version 1 */
+select FormatType(ParseTypeHandle("Int32" || "?"));
diff --git a/yql/essentials/tests/sql/suites/action/runtime_quote_code.sql b/yql/essentials/tests/sql/suites/action/runtime_quote_code.sql
new file mode 100644
index 0000000000..f13eea773d
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/runtime_quote_code.sql
@@ -0,0 +1,13 @@
+/* postgres can not */
+/* syntax version 1 */
+select
+    FormatCode(QuoteCode(AsAtom("foo"))),
+    FormatCode(QuoteCode(AsTuple())),
+    FormatCode(QuoteCode(AsTuple(AsAtom("foo"),AsAtom("bar")))),
+    FormatCode(QuoteCode(1)),
+    FormatCode(QuoteCode(($x,$y)->{ return $x+$y })),
+    ListMap(ListFromRange(1,4), ($x)->{
+        return FormatCode(QuoteCode(
+            ($y)->{ return $x+$y }
+        ))
+    });
diff --git a/yql/essentials/tests/sql/suites/action/runtime_repr_code.sql b/yql/essentials/tests/sql/suites/action/runtime_repr_code.sql
new file mode 100644
index 0000000000..da17985da4
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/runtime_repr_code.sql
@@ -0,0 +1,12 @@
+/* syntax version 1 */
+/* postgres can not */
+$fact = EvaluateCode(
+    Yql::Fold(
+        ListFromRange(1,11),
+        ReprCode(1),
+        ($item, $state)->{ 
+            return FuncCode("*", $state, ReprCode($item)) 
+        })
+);
+
+select $fact;
diff --git a/yql/essentials/tests/sql/suites/action/runtime_serialize_type.sql b/yql/essentials/tests/sql/suites/action/runtime_serialize_type.sql
new file mode 100644
index 0000000000..ffb1dd0450
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/runtime_serialize_type.sql
@@ -0,0 +1,3 @@
+/* syntax version 1 */
+/* postgres can not */
+select Yql::SerializeTypeHandle(TypeHandle(TypeOf(1)));
diff --git a/yql/essentials/tests/sql/suites/action/runtime_type_kind.sql b/yql/essentials/tests/sql/suites/action/runtime_type_kind.sql
new file mode 100644
index 0000000000..c14ee1753b
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/runtime_type_kind.sql
@@ -0,0 +1,8 @@
+/* syntax version 1 */
+/* postgres can not */
+select 
+    TypeKind(TypeHandle(TypeOf(1))),
+    TypeKind(TypeHandle(TypeOf(AsList(1)))),
+    TypeKind(TypeHandle(TypeOf(NULL))),
+    TypeKind(TypeHandle(TypeOf(TypeOf(1)))),
+    TypeKind(TypeHandle(TypeOf(AsAtom("1"))));
diff --git a/yql/essentials/tests/sql/suites/action/runtime_type_splitmake.sql b/yql/essentials/tests/sql/suites/action/runtime_type_splitmake.sql
new file mode 100644
index 0000000000..40cd8abeb0
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/runtime_type_splitmake.sql
@@ -0,0 +1,54 @@
+/* syntax version 1 */
+/* postgres can not */
+$formatTagged = ($x)->{return AsStruct(FormatType($x.Base) as Base, $x.Tag as Tag)};
+$formatArgument = ($x)->{return AsStruct(FormatType($x.Type) as Type, $x.Name as Name, $x.Flags as Flags)};
+$formatCallable = ($x)->{return AsStruct(
+    $x.OptionalArgumentsCount as OptionalArgumentsCount,
+    $x.Payload as Payload,
+    FormatType($x.Result) as Result,
+    ListMap($x.Arguments, $formatArgument) as Arguments
+)};
+
+select
+    DataTypeComponents(ParseTypeHandle("Int32")),
+    DataTypeComponents(ParseTypeHandle("Decimal(4,1)")),
+    FormatType(DataTypeHandle(AsList("Int32"))),
+    FormatType(DataTypeHandle(AsList("Decimal","4","1"))),
+    FormatType(OptionalItemType(ParseTypeHandle("Int32?"))),
+    FormatType(OptionalTypeHandle(ParseTypeHandle("Int32"))),
+    FormatType(ListItemType(ParseTypeHandle("List<Int32>"))),
+    FormatType(ListTypeHandle(ParseTypeHandle("Int32"))),
+    FormatType(StreamItemType(ParseTypeHandle("Stream<Int32>"))),
+    FormatType(StreamTypeHandle(ParseTypeHandle("Int32"))),
+    ListMap(
+        TupleTypeComponents(ParseTypeHandle("Tuple<Int32,String>")),
+        ($x)->{return FormatType($x)}),
+    FormatType(TupleTypeHandle(ListMap(
+        AsList("Int32","String"), ($x)->{return ParseTypeHandle($x)}))),
+    ListMap(
+        StructTypeComponents(ParseTypeHandle("Struct<foo:Int32,bar:String>")),
+        ($x)->{return AsTuple($x.Name, FormatType($x.Type))}),
+    FormatType(StructTypeHandle(ListMap(
+        AsList(AsTuple("foo", "Int32"),AsTuple("bar", "String")), 
+        ($x)->{return AsStruct($x.0 as Name,ParseTypeHandle($x.1) as Type)}))),
+    StaticMap(DictTypeComponents(ParseTypeHandle("Dict<String,Int32>")),
+        ($x)->{return FormatType($x)}),
+    FormatType(DictTypeHandle(ParseTypeHandle("String"),ParseTypeHandle("Int32"))),
+    ResourceTypeTag(ParseTypeHandle("Resource<foo>")),
+    FormatType(ResourceTypeHandle("foo")),
+    $formatTagged(TaggedTypeComponents(ParseTypeHandle("Tagged<String,foo>"))),
+    FormatType(TaggedTypeHandle(ParseTypeHandle("String"),"foo")),
+    FormatType(VariantUnderlyingType(ParseTypeHandle("Variant<Int32,String>"))),
+    FormatType(VariantTypeHandle(ParseTypeHandle("Tuple<Int32,String>"))),
+    FormatType(VariantUnderlyingType(ParseTypeHandle("Variant<a:Int32,b:String>"))),
+    FormatType(VariantTypeHandle(ParseTypeHandle("Struct<a:Int32,b:String>"))),
+    FormatType(VoidTypeHandle()),
+    FormatType(NullTypeHandle()),
+    $formatCallable(CallableTypeComponents(ParseTypeHandle("(Int32,[bar:Double?{Flags:AutoMap}])->String{Payload:foo}"))),
+    FormatType(CallableTypeHandle(ParseTypeHandle("String"),AsList(
+        CallableArgument(ParseTypeHandle("Int32")),
+        CallableArgument(ParseTypeHandle("Double?"), "bar", AsList("AutoMap"))))),
+    FormatType(CallableTypeHandle(ParseTypeHandle("String"),AsList(
+        CallableArgument(ParseTypeHandle("Int32")),
+        CallableArgument(ParseTypeHandle("Double?"), "bar", AsList("AutoMap"))), 
+        1, "foo"));
diff --git a/yql/essentials/tests/sql/suites/action/select_from_subquery_with_orderby.sql b/yql/essentials/tests/sql/suites/action/select_from_subquery_with_orderby.sql
new file mode 100644
index 0000000000..fbc0f689d8
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/select_from_subquery_with_orderby.sql
@@ -0,0 +1,12 @@
+/* postgres can not */
+/* syntax version 1 */
+define subquery $src() as
+  select * from plato.Input order by subkey;
+end define;
+
+define subquery $src_non_yt() as
+  select * from as_table([<|key:1, subkey:1|>, <|key:2, subkey:2|>]) order by subkey;
+end define;
+
+select * from $src() order by key;
+select * from $src_non_yt() order by key;
diff --git a/yql/essentials/tests/sql/suites/action/subquery.sql b/yql/essentials/tests/sql/suites/action/subquery.sql
new file mode 100644
index 0000000000..60df127bd5
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/subquery.sql
@@ -0,0 +1,21 @@
+/* syntax version 1 */
+/* postgres can not */
+use plato;
+
+define subquery $q($name, $a) as
+    $i = (select * from $name);
+    $b = "_foo";
+    select key || $a || $b as key from $i;
+end define;
+
+$z = (select key from $q("Input", "_bar"));
+
+select $z;
+
+select key from $q("Input", "_baz") order by key;
+
+define subquery $e() as
+    select "hello";
+end define;
+
+process $e();
diff --git a/yql/essentials/tests/sql/suites/action/subquery_accessnode.sql b/yql/essentials/tests/sql/suites/action/subquery_accessnode.sql
new file mode 100644
index 0000000000..5cd354945e
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/subquery_accessnode.sql
@@ -0,0 +1,8 @@
+/* syntax version 1 */
+/* postgres can not */
+
+define subquery $foo() as
+  select <|a: 1, b: 2|> as s;
+end define;
+
+select s.a as a, s.b as b from $foo();
diff --git a/yql/essentials/tests/sql/suites/action/subquery_assumeorderby.sql b/yql/essentials/tests/sql/suites/action/subquery_assumeorderby.sql
new file mode 100644
index 0000000000..08c1779801
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/subquery_assumeorderby.sql
@@ -0,0 +1,9 @@
+/* syntax version 1 */
+/* postgres can not */
+define subquery $sub() as
+   select * from (values (1),(2),(3)) as a(x);
+end define;
+
+$sub2 = SubqueryAssumeOrderBy($sub, [("x",true)]);
+
+process $sub2();
\ No newline at end of file
diff --git a/yql/essentials/tests/sql/suites/action/subquery_extend_over_extend_for.sql b/yql/essentials/tests/sql/suites/action/subquery_extend_over_extend_for.sql
new file mode 100644
index 0000000000..08951c5c36
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/subquery_extend_over_extend_for.sql
@@ -0,0 +1,11 @@
+/* syntax version 1 */
+/* postgres can not */
+DEFINE SUBQUERY $sub($i) as
+    SELECT $i as x;
+END DEFINE;
+
+$s = SubqueryExtendFor([1,2,3],$sub);
+$s2 = SubqueryExtendFor([1,2,3],$sub);
+
+$s3 = SubqueryExtend($s, $s2);
+PROCESS $s3();
diff --git a/yql/essentials/tests/sql/suites/action/subquery_merge1.sql b/yql/essentials/tests/sql/suites/action/subquery_merge1.sql
new file mode 100644
index 0000000000..ae6d563701
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/subquery_merge1.sql
@@ -0,0 +1,25 @@
+/* syntax version 1 */
+/* postgres can not */
+define subquery $sub1() as 
+    select 1 as x;
+end define;
+
+define subquery $sub2() as 
+    select 2 as x;
+end define;
+
+define subquery $sub3() as 
+    select 3 as y;
+end define;
+
+$s = SubqueryExtend($sub1,$sub2);
+process $s();
+
+$s = SubqueryUnionAll($sub1,$sub3);
+process $s();
+
+$s = SubqueryMerge($sub1,$sub2);
+process $s();
+
+$s = SubqueryUnionMerge($sub1,$sub3);
+process $s();
diff --git a/yql/essentials/tests/sql/suites/action/subquery_merge2.sql b/yql/essentials/tests/sql/suites/action/subquery_merge2.sql
new file mode 100644
index 0000000000..f8d4918c83
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/subquery_merge2.sql
@@ -0,0 +1,17 @@
+/* syntax version 1 */
+/* postgres can not */
+define subquery $sub($i) as 
+    select $i as x;
+end define;
+
+$s = SubqueryExtendFor([1,2,3],$sub);
+process $s();
+
+$s = SubqueryUnionAllFor([1,2,3],$sub);
+process $s();
+
+$s = SubqueryMergeFor([1,2,3],$sub);
+process $s();
+
+$s = SubqueryUnionMergeFor([1,2,3],$sub);
+process $s();
diff --git a/yql/essentials/tests/sql/suites/action/subquery_merge_evaluate.sql b/yql/essentials/tests/sql/suites/action/subquery_merge_evaluate.sql
new file mode 100644
index 0000000000..25c3a000fa
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/subquery_merge_evaluate.sql
@@ -0,0 +1,16 @@
+/* syntax version 1 */
+/* postgres can not */
+use plato;
+
+define subquery $sub1($i,$j?) as
+   select $i - 1,$j;
+end define;
+
+define subquery $sub2($i,$j?) as
+   select $i + 1,$j;
+end define;
+
+$sub = EvaluateCode(If(1>2,QuoteCode($sub1),QuoteCode($sub2)));
+
+$s = SubqueryExtendFor([1,2,3],$sub);
+process $s();
diff --git a/yql/essentials/tests/sql/suites/action/subquery_merge_nested_subquery.cfg b/yql/essentials/tests/sql/suites/action/subquery_merge_nested_subquery.cfg
new file mode 100644
index 0000000000..58878f8945
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/subquery_merge_nested_subquery.cfg
@@ -0,0 +1 @@
+in Input input.txt
diff --git a/yql/essentials/tests/sql/suites/action/subquery_merge_nested_subquery.sql b/yql/essentials/tests/sql/suites/action/subquery_merge_nested_subquery.sql
new file mode 100644
index 0000000000..47317a548e
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/subquery_merge_nested_subquery.sql
@@ -0,0 +1,16 @@
+/* syntax version 1 */
+/* postgres can not */
+USE plato;
+
+DEFINE SUBQUERY $get_tables_list($dir) AS
+        SELECT
+            Unwrap($dir || "/" || CAST(TableName(Path, "yt") AS String)) AS Path,
+        FROM FOLDER($dir)
+END DEFINE;
+
+DEFINE SUBQUERY $get_all_tables_list($dirs) AS
+        $get_src_tables = SubqueryExtendFor(UNWRAP(ListUniq($dirs)), $get_tables_list);
+        select * from $get_src_tables();
+END DEFINE;
+    
+process $get_all_tables_list([""]);
diff --git a/yql/essentials/tests/sql/suites/action/subquery_merge_nested_world.sql b/yql/essentials/tests/sql/suites/action/subquery_merge_nested_world.sql
new file mode 100644
index 0000000000..67f0683145
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/subquery_merge_nested_world.sql
@@ -0,0 +1,15 @@
+/* syntax version 1 */
+/* postgres can not */
+use plato; 
+
+DEFINE SUBQUERY $s($_i) AS
+    $t = SELECT AGGREGATE_LIST(Path) FROM FOLDER('') WHERE Path LIKE "Input%";
+    SELECT
+        *
+    FROM EACH($t);
+END DEFINE;
+
+$extractor = SubqueryMergeFor([1], $s);
+
+SELECT *
+FROM $extractor(); 
diff --git a/yql/essentials/tests/sql/suites/action/subquery_opt_args.sql b/yql/essentials/tests/sql/suites/action/subquery_opt_args.sql
new file mode 100644
index 0000000000..b3c1c8a757
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/subquery_opt_args.sql
@@ -0,0 +1,8 @@
+/* syntax version 1 */
+/* postgres can not */
+define subquery $sub($a,$b?) as
+    select $a + ($b ?? 0);
+end define;
+
+process $sub(1);
+process $sub(2, 3);
diff --git a/yql/essentials/tests/sql/suites/action/subquery_orderby0.sql b/yql/essentials/tests/sql/suites/action/subquery_orderby0.sql
new file mode 100644
index 0000000000..e281e537cc
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/subquery_orderby0.sql
@@ -0,0 +1,13 @@
+/* syntax version 1 */
+/* postgres can not */
+define subquery $sub() as
+   select * from (values (1,'c'),(1,'a'),(3,'b')) as a(x,y);
+end define;
+
+$sub2 = SubqueryOrderBy($sub, []);
+
+process $sub2();
+
+$sub3 = SubqueryOrderBy($sub, ListCreate(Tuple<String,Bool>));
+
+process $sub3();
\ No newline at end of file
diff --git a/yql/essentials/tests/sql/suites/action/subquery_orderby1.sql b/yql/essentials/tests/sql/suites/action/subquery_orderby1.sql
new file mode 100644
index 0000000000..7070defdb5
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/subquery_orderby1.sql
@@ -0,0 +1,9 @@
+/* syntax version 1 */
+/* postgres can not */
+define subquery $sub() as
+   select * from (values (1),(2),(3)) as a(x);
+end define;
+
+$sub2 = SubqueryOrderBy($sub, [("x",false)]);
+
+process $sub2();
\ No newline at end of file
diff --git a/yql/essentials/tests/sql/suites/action/subquery_orderby2.sql b/yql/essentials/tests/sql/suites/action/subquery_orderby2.sql
new file mode 100644
index 0000000000..7dbbe3ad0f
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/subquery_orderby2.sql
@@ -0,0 +1,9 @@
+/* syntax version 1 */
+/* postgres can not */
+define subquery $sub() as
+   select * from (values (1,'c'),(1,'a'),(3,'b')) as a(x,y);
+end define;
+
+$sub2 = SubqueryOrderBy($sub, [("x",false), ("y",true)]);
+
+process $sub2();
\ No newline at end of file
diff --git a/yql/essentials/tests/sql/suites/action/table_content_before_from_folder.cfg b/yql/essentials/tests/sql/suites/action/table_content_before_from_folder.cfg
new file mode 100644
index 0000000000..ad52c79527
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/table_content_before_from_folder.cfg
@@ -0,0 +1,2 @@
+in Input input.txt
+out Output output.txt
diff --git a/yql/essentials/tests/sql/suites/action/table_content_before_from_folder.sql b/yql/essentials/tests/sql/suites/action/table_content_before_from_folder.sql
new file mode 100644
index 0000000000..bd6ee020d4
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/action/table_content_before_from_folder.sql
@@ -0,0 +1,7 @@
+/* syntax version 1 */
+/* postgres can not */
+use plato;
+pragma yt.EvaluationTableSizeLimit="1";
+select * from Input limit 1;
+$tables = (select aggregate_list(Path) as dates from folder("") where Path like "Input%");
+select count(*) from each($tables);