aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorudovichenko-r <rvu@ydb.tech>2022-09-09 16:55:30 +0300
committerudovichenko-r <rvu@ydb.tech>2022-09-09 16:55:30 +0300
commit4e889ffb977c54cf6f845a55831cb759f06454f0 (patch)
tree7d3ca613b9675e36813f55e04cfb30a3991b3655
parentfcecce903b52489c4744186556dfb1ef0ff4d28d (diff)
downloadydb-4e889ffb977c54cf6f845a55831cb759f06454f0.tar.gz
[dq] Disable DQ for external users only when porto is disabled
-rw-r--r--ydb/library/yql/providers/dq/provider/exec/yql_dq_exectransformer.cpp2
-rw-r--r--ydb/library/yql/providers/dq/provider/yql_dq_recapture.cpp2
2 files changed, 2 insertions, 2 deletions
diff --git a/ydb/library/yql/providers/dq/provider/exec/yql_dq_exectransformer.cpp b/ydb/library/yql/providers/dq/provider/exec/yql_dq_exectransformer.cpp
index 2b51232416..6f9ca48e39 100644
--- a/ydb/library/yql/providers/dq/provider/exec/yql_dq_exectransformer.cpp
+++ b/ydb/library/yql/providers/dq/provider/exec/yql_dq_exectransformer.cpp
@@ -657,7 +657,7 @@ private:
TStatusCallbackPair HandleResult(const TExprNode::TPtr& input, TExprContext& ctx) {
YQL_CLOG(DEBUG, ProviderDq) << "Executing " << input->Content() << " (UniqueId=" << input->UniqueId() << ")";
- if (State->ExternalUser) {
+ if (State->ExternalUser && !State->Settings->_EnablePorto.Get().GetOrElse(TDqSettings::TDefault::EnablePorto)) {
return Fallback();
}
diff --git a/ydb/library/yql/providers/dq/provider/yql_dq_recapture.cpp b/ydb/library/yql/providers/dq/provider/yql_dq_recapture.cpp
index 25d7c45d76..86791f7d6c 100644
--- a/ydb/library/yql/providers/dq/provider/yql_dq_recapture.cpp
+++ b/ydb/library/yql/providers/dq/provider/yql_dq_recapture.cpp
@@ -50,7 +50,7 @@ public:
FlushStatistics();
};
- if (State_->ExternalUser) {
+ if (State_->ExternalUser && !State_->Settings->_EnablePorto.Get().GetOrElse(TDqSettings::TDefault::EnablePorto)) {
Statistics_["DqExternalUser"]++;
return TStatus::Ok;
}