File tree Expand file tree Collapse file tree 3 files changed +13
-1
lines changed Expand file tree Collapse file tree 3 files changed +13
-1
lines changed Original file line number Diff line number Diff line change @@ -1590,7 +1590,7 @@ class TKqpProxyService : public TActorBootstrapped<TKqpProxyService> {
15901590 }
15911591
15921592 const auto & poolConfig = poolInfo->Config ;
1593- if (poolConfig. ConcurrentQueryLimit == - 1 && poolConfig. DatabaseLoadCpuThreshold < 0.0 && ! poolConfig. QueryCancelAfter ) {
1593+ if (! NWorkload::IsWorkloadServiceRequired ( poolConfig) ) {
15941594 ev->Get ()->SetPoolConfig (poolConfig);
15951595 }
15961596
Original file line number Diff line number Diff line change @@ -538,6 +538,10 @@ class TKqpWorkloadService : public TActorBootstrapped<TKqpWorkloadService> {
538538
539539} // anonymous namespace
540540
541+ bool IsWorkloadServiceRequired (const NResourcePool::TPoolSettings& config) {
542+ return config.ConcurrentQueryLimit != -1 || config.DatabaseLoadCpuThreshold >= 0.0 || config.QueryCancelAfter ;
543+ }
544+
541545} // namespace NWorkload
542546
543547IActor* CreateKqpWorkloadService (NMonitoring::TDynamicCounterPtr counters) {
Original file line number Diff line number Diff line change 11#pragma once
22
3+ #include < ydb/core/resource_pools/resource_pool_settings.h>
4+
35#include < ydb/library/actors/core/actor.h>
46
57
68namespace NKikimr ::NKqp {
79
10+ namespace NWorkload {
11+
12+ bool IsWorkloadServiceRequired (const NResourcePool::TPoolSettings& config);
13+
14+ } // namespace NWorkload
15+
816NActors::IActor* CreateKqpWorkloadService (NMonitoring::TDynamicCounterPtr counters);
917
1018} // namespace NKikimr::NKqp
You can’t perform that action at this time.
0 commit comments