summaryrefslogtreecommitdiffstats
path: root/yql/essentials/tools/udf_resolver
diff options
context:
space:
mode:
authorvvvv <[email protected]>2025-04-21 20:53:56 +0300
committervvvv <[email protected]>2025-04-21 21:26:59 +0300
commit108c1aa409626aa29ca728edafd01fbbd7a1b00e (patch)
treeb88c1e3b690a29b0ed4f505f05990d656d6373ec /yql/essentials/tools/udf_resolver
parent6b17ad8c52e16d0088291781e1b5a9e28d028b9b (diff)
YQL-19861 abi, udf resolvers, test, pass via yt gateways
commit_hash:6e3f5fac6a8598586987b52d749644d1ce1fccbe
Diffstat (limited to 'yql/essentials/tools/udf_resolver')
-rw-r--r--yql/essentials/tools/udf_resolver/discover.cpp5
-rw-r--r--yql/essentials/tools/udf_resolver/discover.h6
-rw-r--r--yql/essentials/tools/udf_resolver/udf_resolver.cpp2
-rw-r--r--yql/essentials/tools/udf_resolver/ya.make1
4 files changed, 9 insertions, 5 deletions
diff --git a/yql/essentials/tools/udf_resolver/discover.cpp b/yql/essentials/tools/udf_resolver/discover.cpp
index a290917a5a9..530e7d96e98 100644
--- a/yql/essentials/tools/udf_resolver/discover.cpp
+++ b/yql/essentials/tools/udf_resolver/discover.cpp
@@ -66,7 +66,7 @@ NYql::TResolveResult DoDiscover(const NYql::TResolve& inMsg, IMutableFunctionReg
TFunctionTypeInfo funcInfo;
if (!f.second.IsTypeAwareness) {
- auto status = functionRegistry.FindFunctionTypeInfo(env, typeInfoHelper,
+ auto status = functionRegistry.FindFunctionTypeInfo(NYql::UnknownLangVersion, env, typeInfoHelper,
nullptr, funcName, nullptr, nullptr, NUdf::IUdfModule::TFlags::TypesOnly, {}, nullptr, logProvider.Get(), &funcInfo);
if (!status.IsOk()) {
@@ -103,7 +103,8 @@ void Print(const NYql::TResolveResult& result, IOutputStream& out, bool printAsP
out << "UDF count: " << result.UdfsSize() << Endl;
}
-void DiscoverInFiles(const TVector<TString>& udfPaths, IOutputStream& out, bool printAsProto, NYql::NUdf::ELogLevel logLevel) {
+void DiscoverInFiles(const TVector<TString>& udfPaths, IOutputStream& out, bool printAsProto,
+ NYql::NUdf::ELogLevel logLevel) {
NYql::TResolve inMsg;
inMsg.SetRuntimeLogLevel(static_cast<ui32>(logLevel));
for (auto& path : udfPaths) {
diff --git a/yql/essentials/tools/udf_resolver/discover.h b/yql/essentials/tools/udf_resolver/discover.h
index 7c995b7f656..d32d3fa5a5a 100644
--- a/yql/essentials/tools/udf_resolver/discover.h
+++ b/yql/essentials/tools/udf_resolver/discover.h
@@ -9,8 +9,10 @@
#include <util/stream/output.h>
namespace NUdfResolver {
-void DiscoverInDir(const TString& dir, IOutputStream& out, bool printAsProto, NYql::NUdf::ELogLevel logLevel);
-void DiscoverInFile(const TString& filePath, IOutputStream& out, bool printAsProto, NYql::NUdf::ELogLevel logLevel);
+void DiscoverInDir(const TString& dir, IOutputStream& out, bool printAsProto,
+ NYql::NUdf::ELogLevel logLevel);
+void DiscoverInFile(const TString& filePath, IOutputStream& out, bool printAsProto,
+ NYql::NUdf::ELogLevel logLevel);
void Discover(IInputStream& in, IOutputStream& out, bool printAsProto);
void FillImportResultModules(const THashSet<TString>& modules, NYql::TImportResult& importRes);
;
diff --git a/yql/essentials/tools/udf_resolver/udf_resolver.cpp b/yql/essentials/tools/udf_resolver/udf_resolver.cpp
index 27ab6f87d48..03116858f7e 100644
--- a/yql/essentials/tools/udf_resolver/udf_resolver.cpp
+++ b/yql/essentials/tools/udf_resolver/udf_resolver.cpp
@@ -174,7 +174,7 @@ void ResolveUDFs() {
}
TFunctionTypeInfo funcInfo;
- auto status = newRegistry->FindFunctionTypeInfo(env, typeInfoHelper, nullptr,
+ auto status = newRegistry->FindFunctionTypeInfo(udf.GetLangVer(), env, typeInfoHelper, nullptr,
udf.GetName(), mkqlUserType, udf.GetTypeConfig(), NUdf::IUdfModule::TFlags::TypesOnly, {}, nullptr, logProvider.Get(), &funcInfo);
if (!status.IsOk()) {
udfRes->SetError(TStringBuilder() << "Failed to find UDF function: " << udf.GetName()
diff --git a/yql/essentials/tools/udf_resolver/ya.make b/yql/essentials/tools/udf_resolver/ya.make
index 05240ec3b7b..2dff7abf78f 100644
--- a/yql/essentials/tools/udf_resolver/ya.make
+++ b/yql/essentials/tools/udf_resolver/ya.make
@@ -25,6 +25,7 @@ PEERDIR(
yql/essentials/utils/backtrace
yql/essentials/utils/sys
yql/essentials/sql/pg_dummy
+ yql/essentials/public/langver
)
YQL_LAST_ABI_VERSION()