diff options
author | udovichenko-r <rvu@ydb.tech> | 2022-09-09 16:55:30 +0300 |
---|---|---|
committer | udovichenko-r <rvu@ydb.tech> | 2022-09-09 16:55:30 +0300 |
commit | 4e889ffb977c54cf6f845a55831cb759f06454f0 (patch) | |
tree | 7d3ca613b9675e36813f55e04cfb30a3991b3655 | |
parent | fcecce903b52489c4744186556dfb1ef0ff4d28d (diff) | |
download | ydb-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.cpp | 2 | ||||
-rw-r--r-- | ydb/library/yql/providers/dq/provider/yql_dq_recapture.cpp | 2 |
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; } |