Fixed grammar of the transfer

commit_hash:98f460965618cdddf9fc25373b20741b4e85a303

1 files changed, 2 insertions, 2 deletions

diff --git a/yql/essentials/sql/v1/format/sql_format_ut.h b/yql/essentials/sql/v1/format/sql_format_ut.h
index 7f77d456a15..b4986c6aaf1 100644
--- a/yql/essentials/sql/v1/format/sql_format_ut.h
+++ b/yql/essentials/sql/v1/format/sql_format_ut.h
@@ -417,14 +417,14 @@ Y_UNIT_TEST(AsyncReplication) {
 
 Y_UNIT_TEST(Transfer) {
     TCases cases = {
-        {"create transfer user from topic1 to table1 with (user='foo')",
-            "CREATE TRANSFER user FROM topic1 TO table1 WITH (user = 'foo');\n"},
         {"alter transfer user set (user='foo')",
             "ALTER TRANSFER user SET (user = 'foo');\n"},
         {"drop transfer user",
             "DROP TRANSFER user;\n"},
         {"drop transfer user cascade",
             "DROP TRANSFER user CASCADE;\n"},
+        {"create transfer user from topic1 to table1 using ($x) -> { $y = cast($x as String); return $y ; }",
+            "CREATE TRANSFER user FROM topic1 TO table1 USING ($x) -> {\n    $y = CAST($x AS String);\n    RETURN $y;\n};\n"},
         {"create transfer user from topic1 to table1 using ($x) -> { $y = cast($x as String); return $y ; } with (user='foo')",
             "CREATE TRANSFER user FROM topic1 TO table1 USING ($x) -> {\n    $y = CAST($x AS String);\n    RETURN $y;\n} WITH (user = 'foo');\n"},
         {"create transfer user from topic1 to table1 using $xxx with (user='foo')",