Renamed KikimrProviderExecution to PassiveExecution

GrigoriyPA · Feb 16, 2024 · a4f69e4 · a4f69e4
1 parent dc962e1
commit a4f69e4
Show file tree

Hide file tree

Showing 5 changed files with 16 additions and 16 deletions.
diff --git a/ydb/core/kqp/host/kqp_host.cpp b/ydb/core/kqp/host/kqp_host.cpp
@@ -1516,7 +1516,7 @@ class TKqpHost : public IKqpHost {
 
         auto [ytState, statWriter] = CreateYtNativeState(FederatedQuerySetup->YtGateway, userName, SessionId, &FederatedQuerySetup->YtGatewayConfig, TypesCtx);
 
-        ytState->KikimrProviderExecution = true;
+        ytState->PassiveExecution = true;
         ytState->Gateway->OpenSession(
             IYtGateway::TOpenSessionOptions(SessionId)
                 .UserName(userName)

diff --git a/ydb/library/yql/providers/yt/provider/yql_yt_datasink_finalize.cpp b/ydb/library/yql/providers/yt/provider/yql_yt_datasink_finalize.cpp
@@ -17,7 +17,7 @@ class TYtDataSinkFinalizingTransformer: public TAsyncCallbackTransformer<TYtData
         Y_UNUSED(ctx);
         output = input;
 
-        if (State_->KikimrProviderExecution) {
+        if (State_->PassiveExecution) {
             return SyncStatus(IGraphTransformer::TStatus::Ok);
         }
 

diff --git a/ydb/library/yql/providers/yt/provider/yql_yt_datasource.cpp b/ydb/library/yql/providers/yt/provider/yql_yt_datasource.cpp
@@ -195,7 +195,7 @@ class TYtDataSource : public TDataProviderBase {
         bool buildLeft = TCoLeft::Match(node.Get());
         bool buildReadTableScheme = NYql::HasSetting(read.Arg(4).Ref(), EYtSettingType::Scheme);
 
-        if (buildLeft && (buildReadTableScheme || !State_->KikimrProviderExecution)) {
+        if (buildLeft && (buildReadTableScheme || !State_->PassiveExecution)) {
             return read.World().Ptr();
         }
 

diff --git a/ydb/library/yql/providers/yt/provider/yql_yt_physical_optimize.cpp b/ydb/library/yql/providers/yt/provider/yql_yt_physical_optimize.cpp
@@ -1489,7 +1489,7 @@ class TYtPhysicalOptProposalTransformer : public TOptimizeTransformerBase {
 
     template<bool IsTop>
     TMaybeNode<TExprBase> Sort(TExprBase node, TExprContext& ctx) const {
-        if (State_->Types->EvaluationInProgress || State_->KikimrProviderExecution) {
+        if (State_->Types->EvaluationInProgress || State_->PassiveExecution) {
             return node;
         }
 
@@ -1728,7 +1728,7 @@ class TYtPhysicalOptProposalTransformer : public TOptimizeTransformerBase {
     }
 
     TMaybeNode<TExprBase> PartitionByKey(TExprBase node, TExprContext& ctx) const {
-        if (State_->Types->EvaluationInProgress || State_->KikimrProviderExecution) {
+        if (State_->Types->EvaluationInProgress || State_->PassiveExecution) {
             return node;
         }
 
@@ -2599,7 +2599,7 @@ class TYtPhysicalOptProposalTransformer : public TOptimizeTransformerBase {
     }
 
     TMaybeNode<TExprBase> FlatMap(TExprBase node, TExprContext& ctx, const TGetParents& getParents) const {
-        if (State_->Types->EvaluationInProgress || State_->KikimrProviderExecution) {
+        if (State_->Types->EvaluationInProgress || State_->PassiveExecution) {
             return node;
         }
 
@@ -2684,7 +2684,7 @@ class TYtPhysicalOptProposalTransformer : public TOptimizeTransformerBase {
     }
 
     TMaybeNode<TExprBase> CombineByKey(TExprBase node, TExprContext& ctx) const {
-        if (State_->Types->EvaluationInProgress || State_->KikimrProviderExecution) {
+        if (State_->Types->EvaluationInProgress || State_->PassiveExecution) {
             return node;
         }
 
@@ -2872,7 +2872,7 @@ class TYtPhysicalOptProposalTransformer : public TOptimizeTransformerBase {
     }
 
     TMaybeNode<TExprBase> DqWrite(TExprBase node, TExprContext& ctx, IOptimizationContext& optCtx, const TGetParents& getParents) const {
-        if (State_->KikimrProviderExecution) {
+        if (State_->PassiveExecution) {
             return node;
         }
 
@@ -3362,7 +3362,7 @@ class TYtPhysicalOptProposalTransformer : public TOptimizeTransformerBase {
     }
 
     TMaybeNode<TExprBase> Fill(TExprBase node, TExprContext& ctx) const {
-        if (State_->KikimrProviderExecution) {
+        if (State_->PassiveExecution) {
             return node;
         }
 
@@ -3516,7 +3516,7 @@ class TYtPhysicalOptProposalTransformer : public TOptimizeTransformerBase {
     }
 
     TMaybeNode<TExprBase> Extend(TExprBase node, TExprContext& ctx) const {
-        if (State_->KikimrProviderExecution) {
+        if (State_->PassiveExecution) {
             return node;
         }
 
@@ -4345,7 +4345,7 @@ class TYtPhysicalOptProposalTransformer : public TOptimizeTransformerBase {
 
     template <typename TLMapType>
     TMaybeNode<TExprBase> LMap(TExprBase node, TExprContext& ctx) const {
-        if (State_->Types->EvaluationInProgress || State_->KikimrProviderExecution) {
+        if (State_->Types->EvaluationInProgress || State_->PassiveExecution) {
             return node;
         }
 
@@ -4878,7 +4878,7 @@ class TYtPhysicalOptProposalTransformer : public TOptimizeTransformerBase {
     }
 
     TMaybeNode<TExprBase> AssumeSorted(TExprBase node, TExprContext& ctx, const TGetParents& getParents) const {
-        if (State_->Types->EvaluationInProgress || State_->KikimrProviderExecution) {
+        if (State_->Types->EvaluationInProgress || State_->PassiveExecution) {
             return node;
         }
 
@@ -5535,7 +5535,7 @@ class TYtPhysicalOptProposalTransformer : public TOptimizeTransformerBase {
     }
 
     TMaybeNode<TExprBase> EquiJoin(TExprBase node, TExprContext& ctx, const TGetParents& getParents) const {
-        if (State_->Types->EvaluationInProgress || State_->KikimrProviderExecution) {
+        if (State_->Types->EvaluationInProgress || State_->PassiveExecution) {
             return node;
         }
 
@@ -6157,7 +6157,7 @@ class TYtPhysicalOptProposalTransformer : public TOptimizeTransformerBase {
     }
 
     TMaybeNode<TExprBase> ReadWithSettings(TExprBase node, TExprContext& ctx) const {
-        if (State_->KikimrProviderExecution) {
+        if (State_->PassiveExecution) {
             return node;
         }
 
@@ -6237,7 +6237,7 @@ class TYtPhysicalOptProposalTransformer : public TOptimizeTransformerBase {
     }
 
     TMaybeNode<TExprBase> ReplaceStatWriteTable(TExprBase node, TExprContext& ctx) const {
-        if (State_->KikimrProviderExecution) {
+        if (State_->PassiveExecution) {
             return node;
         }
 

diff --git a/ydb/library/yql/providers/yt/provider/yql_yt_provider.h b/ydb/library/yql/providers/yt/provider/yql_yt_provider.h
@@ -102,7 +102,7 @@ struct TYtState : public TThrRefBase {
     THolder<IDqIntegration> DqIntegration_;
     ui32 NextEpochId = 1;
     bool OnlyNativeExecution = false;
-    bool KikimrProviderExecution = false;
+    bool PassiveExecution = false;
     TDuration TimeSpentInHybrid;
     NMonotonic::TMonotonic HybridStartTime;
     std::unordered_set<ui32> HybridInFlightOprations;