YQL-19845 pass langver to purecalc's compute

commit_hash:cb5d5094d0c0d7c7e07bed78fed7c15e9a0c1a29

Author: vitstn

yql/essentials/public/purecalc/common/worker.cpp

@@ -44,7 +44,8 @@ TWorkerGraph::TWorkerGraph(
     const TString& LLVMSettings,
     NKikimr::NUdf::ICountersProvider* countersProvider,
     ui64 nativeYtTypeFlags,
-    TMaybe<ui64> deterministicTimeProviderSeed
+    TMaybe<ui64> deterministicTimeProviderSeed,
+    TLangVersion langver
 )
     : ScopedAlloc_(__LOCATION__, NKikimr::TAlignedPagePoolCounters(), funcRegistry.SupportsSizedAllocators())
     , Env_(ScopedAlloc_)
@@ -77,7 +78,7 @@ TWorkerGraph::TWorkerGraph(
 
     // Setup struct types
 
-    NKikimr::NMiniKQL::TProgramBuilder pgmBuilder(Env_, FuncRegistry_);
+    NKikimr::NMiniKQL::TProgramBuilder pgmBuilder(Env_, FuncRegistry_, false, langver);
     for (ui32 i = 0; i < inputsCount; ++i) {
         const auto* type = static_cast<NKikimr::NMiniKQL::TStructType*>(NCommon::BuildType(TPositionHandle(), *inputTypes[i], pgmBuilder, typeMemoization));
         const auto* originalType = type;
@@ -157,7 +158,10 @@ TWorkerGraph::TWorkerGraph(
         LLVMSettings,
         NKikimr::NMiniKQL::EGraphPerProcess::Multi,
         nullptr,
-        countersProvider);
+        countersProvider,
+        nullptr,
+        nullptr,
+        langver);
 
     ComputationPattern_ = NKikimr::NMiniKQL::MakeComputationPattern(
         explorer,
@@ -196,12 +200,13 @@ TWorker<TBase>::TWorker(
     const TString& LLVMSettings,
     NKikimr::NUdf::ICountersProvider* countersProvider,
     ui64 nativeYtTypeFlags,
-    TMaybe<ui64> deterministicTimeProviderSeed
+    TMaybe<ui64> deterministicTimeProviderSeed,
+    TLangVersion langver
 )
     : WorkerFactory_(std::move(factory))
     , Graph_(exprRoot, exprCtx, serializedProgram, funcRegistry, userData,
          inputTypes, originalInputTypes, rawInputTypes, outputType, rawOutputType,
-         LLVMSettings, countersProvider, nativeYtTypeFlags, deterministicTimeProviderSeed)
+         LLVMSettings, countersProvider, nativeYtTypeFlags, deterministicTimeProviderSeed, langver)
 {
 }
 

yql/essentials/public/purecalc/common/worker.h

@@ -30,7 +30,8 @@ namespace NYql {
                 const TString& LLVMSettings,
                 NKikimr::NUdf::ICountersProvider* countersProvider,
                 ui64 nativeYtTypeFlags,
-                TMaybe<ui64> deterministicTimeProviderSeed
+                TMaybe<ui64> deterministicTimeProviderSeed,
+                TLangVersion langver
             );
 
             ~TWorkerGraph();
@@ -80,7 +81,8 @@ namespace NYql {
                 const TString& LLVMSettings,
                 NKikimr::NUdf::ICountersProvider* countersProvider,
                 ui64 nativeYtTypeFlags,
-                TMaybe<ui64> deterministicTimeProviderSeed
+                TMaybe<ui64> deterministicTimeProviderSeed,
+                TLangVersion langver
             );
 
         public:

yql/essentials/public/purecalc/common/worker_factory.cpp

@@ -56,6 +56,7 @@ TWorkerFactory<TBase>::TWorkerFactory(TWorkerFactoryOptions options, EProcessorM
     , DeterministicTimeProviderSeed_(options.DeterministicTimeProviderSeed_)
     , UseSystemColumns_(options.UseSystemColumns)
     , UseWorkerPool_(options.UseWorkerPool)
+    , LangVer_(options.LangVer_)
 {
     // Prepare input struct types and extract all column names from inputs
 
@@ -300,7 +301,8 @@ TExprNode::TPtr TWorkerFactory<TBase>::Compile(
             LLVMSettings_,
             CountersProvider_,
             NativeYtTypeFlags_,
-            DeterministicTimeProviderSeed_
+            DeterministicTimeProviderSeed_,
+            langver
         );
 
         with_lock (graph.ScopedAlloc_) {
@@ -551,7 +553,8 @@ void TWorkerFactory<TBase>::ReturnWorker(IWorker* worker) {
             LLVMSettings_,                                                              \
             CountersProvider_,                                                          \
             NativeYtTypeFlags_,                                                         \
-            DeterministicTimeProviderSeed_                                              \
+            DeterministicTimeProviderSeed_,                                             \
+            LangVer_                                                                    \
         ));                                                                             \
     }
 

yql/essentials/public/purecalc/common/worker_factory.h

@@ -107,6 +107,7 @@ namespace NYql {
             TMaybe<ui64> DeterministicTimeProviderSeed_;
             bool UseSystemColumns_;
             bool UseWorkerPool_;
+            TLangVersion LangVer_;
             TVector<THolder<IWorker>> WorkerPool_;
 
         public: