Intermediate changes

commit_hash:09ab1ce3454875bee93b7f9bfd0d95f7f482fac8

2 files changed, 20 insertions, 0 deletions

diff --git a/yt/yql/tests/sql/suites/ytflow/attached_udf.cfg b/yt/yql/tests/sql/suites/ytflow/attached_udf.cfg
new file mode 100644
index 00000000000..039a6a8210a
--- /dev/null
+++ b/yt/yql/tests/sql/suites/ytflow/attached_udf.cfg
@@ -0,0 +1,4 @@
+in Input input.txt
+out Output output.txt
+providers ytflow
+file custom_string_udf.so yql/essentials/udfs/common/string/libstring_udf.so
diff --git a/yt/yql/tests/sql/suites/ytflow/attached_udf.yql b/yt/yql/tests/sql/suites/ytflow/attached_udf.yql
new file mode 100644
index 00000000000..e582253ffba
--- /dev/null
+++ b/yt/yql/tests/sql/suites/ytflow/attached_udf.yql
@@ -0,0 +1,16 @@
+use plato;
+
+pragma Engine = "ytflow";
+
+pragma Ytflow.Cluster = "plato";
+pragma Ytflow.PipelineDirectory = "pipelines";
+pragma Ytflow.PipelineName = "test";
+
+pragma Udf("custom_string_udf.so");
+
+insert into Output
+select 
+    String::AsciiToUpper(string_field) as string_field,
+    LENGTH(string_field) as int64_field,
+    String::Contains(string_field, "bar") as bool_field
+from Input;