Skip to content

Commit 68e7f2d

Browse files
GrigoriyPAGrigoriyPA
authored
Merge c13a63b into 82d8441 
2 parents 82d8441 + c13a63b commit 68e7f2d

24 files changed

+66
-120
lines changed

‎ydb/core/driver_lib/run/kikimr_services_initializers.cpp

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2130,15 +2130,15 @@ void TKqpServiceInitializer::InitializeServices(NActors::TActorSystemSetup* setu
21302130
auto federatedQuerySetupFactory = NKqp::MakeKqpFederatedQuerySetupFactory(setup, appData, Config);
21312131

21322132
auto proxy = NKqp::CreateKqpProxyService(Config.GetLogConfig(), Config.GetTableServiceConfig(),
2133-
Config.GetQueryServiceConfig(), Config.GetMetadataProviderConfig(), std::move(settings), Factories->QueryReplayBackendFactory, std::move(kqpProxySharedResources),
2133+
Config.GetQueryServiceConfig(), std::move(settings), Factories->QueryReplayBackendFactory, std::move(kqpProxySharedResources),
21342134
federatedQuerySetupFactory
21352135
);
21362136
setup->LocalServices.push_back(std::make_pair(
21372137
NKqp::MakeKqpProxyID(NodeId),
21382138
TActorSetupCmd(proxy, TMailboxType::HTSwap, appData->UserPoolId)));
21392139

21402140
// Create finalize script service
2141-
auto finalize = NKqp::CreateKqpFinalizeScriptService(Config.GetQueryServiceConfig(), Config.GetMetadataProviderConfig(), federatedQuerySetupFactory);
2141+
auto finalize = NKqp::CreateKqpFinalizeScriptService(Config.GetQueryServiceConfig(), federatedQuerySetupFactory);
21422142
setup->LocalServices.push_back(std::make_pair(
21432143
NKqp::MakeKqpFinalizeScriptServiceId(NodeId),
21442144
TActorSetupCmd(finalize, TMailboxType::HTSwap, appData->UserPoolId)));

‎ydb/core/kqp/compile_service/kqp_compile_actor.cpp

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,6 @@ class TKqpCompileActor : public TActorBootstrapped<TKqpCompileActor> {
4545
TKqpCompileActor(const TActorId& owner, const TKqpSettings::TConstPtr& kqpSettings,
4646
const TTableServiceConfig& tableServiceConfig,
4747
const TQueryServiceConfig& queryServiceConfig,
48-
const NKikimrConfig::TMetadataProviderConfig& metadataProviderConfig,
4948
TIntrusivePtr<TModuleResolverState> moduleResolverState, TIntrusivePtr<TKqpCounters> counters,
5049
const TString& uid, const TKqpQueryId& queryId,
5150
const TIntrusiveConstPtr<NACLib::TUserToken>& userToken,
@@ -64,7 +63,6 @@ class TKqpCompileActor : public TActorBootstrapped<TKqpCompileActor> {
6463
, DbCounters(dbCounters)
6564
, Config(MakeIntrusive<TKikimrConfiguration>())
6665
, QueryServiceConfig(queryServiceConfig)
67-
, MetadataProviderConfig(metadataProviderConfig)
6866
, CompilationTimeout(TDuration::MilliSeconds(tableServiceConfig.GetCompileTimeoutMs()))
6967
, UserRequestContext(userRequestContext)
7068
, CompileActorSpan(TWilsonKqp::CompileActor, std::move(traceId), "CompileActor")
@@ -463,7 +461,6 @@ class TKqpCompileActor : public TActorBootstrapped<TKqpCompileActor> {
463461
TKqpDbCountersPtr DbCounters;
464462
TKikimrConfiguration::TPtr Config;
465463
TQueryServiceConfig QueryServiceConfig;
466-
TMetadataProviderConfig MetadataProviderConfig;
467464
TDuration CompilationTimeout;
468465
TInstant StartTime;
469466
TDuration CompileCpuTime;
@@ -523,15 +520,14 @@ void ApplyServiceConfig(TKikimrConfiguration& kqpConfig, const TTableServiceConf
523520
IActor* CreateKqpCompileActor(const TActorId& owner, const TKqpSettings::TConstPtr& kqpSettings,
524521
const TTableServiceConfig& tableServiceConfig,
525522
const TQueryServiceConfig& queryServiceConfig,
526-
const TMetadataProviderConfig& metadataProviderConfig,
527523
TIntrusivePtr<TModuleResolverState> moduleResolverState, TIntrusivePtr<TKqpCounters> counters,
528524
const TString& uid, const TKqpQueryId& query, const TIntrusiveConstPtr<NACLib::TUserToken>& userToken,
529525
std::optional<TKqpFederatedQuerySetup> federatedQuerySetup,
530526
TKqpDbCountersPtr dbCounters, const TIntrusivePtr<TUserRequestContext>& userRequestContext,
531527
NWilson::TTraceId traceId, TKqpTempTablesState::TConstPtr tempTablesState,
532528
ECompileActorAction compileAction, TMaybe<TQueryAst> astResult, bool collectFullDiagnostics)
533529
{
534-
return new TKqpCompileActor(owner, kqpSettings, tableServiceConfig, queryServiceConfig, metadataProviderConfig,
530+
return new TKqpCompileActor(owner, kqpSettings, tableServiceConfig, queryServiceConfig,
535531
moduleResolverState, counters,
536532
uid, query, userToken, dbCounters,
537533
federatedQuerySetup, userRequestContext,

‎ydb/core/kqp/compile_service/kqp_compile_service.cpp

Lines changed: 4 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -394,14 +394,13 @@ class TKqpCompileService : public TActorBootstrapped<TKqpCompileService> {
394394
}
395395

396396
TKqpCompileService(const TTableServiceConfig& tableServiceConfig, const TQueryServiceConfig& queryServiceConfig,
397-
const TMetadataProviderConfig& metadataProviderConfig, const TKqpSettings::TConstPtr& kqpSettings,
397+
const TKqpSettings::TConstPtr& kqpSettings,
398398
TIntrusivePtr<TModuleResolverState> moduleResolverState, TIntrusivePtr<TKqpCounters> counters,
399399
std::shared_ptr<IQueryReplayBackendFactory> queryReplayFactory,
400400
std::optional<TKqpFederatedQuerySetup> federatedQuerySetup
401401
)
402402
: TableServiceConfig(tableServiceConfig)
403403
, QueryServiceConfig(queryServiceConfig)
404-
, MetadataProviderConfig(metadataProviderConfig)
405404
, KqpSettings(kqpSettings)
406405
, ModuleResolverState(moduleResolverState)
407406
, Counters(counters)
@@ -962,7 +961,7 @@ class TKqpCompileService : public TActorBootstrapped<TKqpCompileService> {
962961
}
963962

964963
void StartCompilation(TKqpCompileRequest&& request, const TActorContext& ctx) {
965-
auto compileActor = CreateKqpCompileActor(ctx.SelfID, KqpSettings, TableServiceConfig, QueryServiceConfig, MetadataProviderConfig, ModuleResolverState, Counters,
964+
auto compileActor = CreateKqpCompileActor(ctx.SelfID, KqpSettings, TableServiceConfig, QueryServiceConfig, ModuleResolverState, Counters,
966965
request.Uid, request.Query, request.UserToken, FederatedQuerySetup, request.DbCounters, request.UserRequestContext,
967966
request.CompileServiceSpan.GetTraceId(), request.TempTablesState, request.Action, std::move(request.AstResult), CollectDiagnostics);
968967
auto compileActorId = ctx.ExecutorThread.RegisterActor(compileActor, TMailboxType::HTSwap,
@@ -1044,7 +1043,6 @@ class TKqpCompileService : public TActorBootstrapped<TKqpCompileService> {
10441043
private:
10451044
TTableServiceConfig TableServiceConfig;
10461045
TQueryServiceConfig QueryServiceConfig;
1047-
TMetadataProviderConfig MetadataProviderConfig;
10481046
TKqpSettings::TConstPtr KqpSettings;
10491047
TIntrusivePtr<TModuleResolverState> ModuleResolverState;
10501048
TIntrusivePtr<TKqpCounters> Counters;
@@ -1059,13 +1057,12 @@ class TKqpCompileService : public TActorBootstrapped<TKqpCompileService> {
10591057
};
10601058

10611059
IActor* CreateKqpCompileService(const TTableServiceConfig& tableServiceConfig, const TQueryServiceConfig& queryServiceConfig,
1062-
const TMetadataProviderConfig& metadataProviderConfig, const TKqpSettings::TConstPtr& kqpSettings,
1063-
TIntrusivePtr<TModuleResolverState> moduleResolverState, TIntrusivePtr<TKqpCounters> counters,
1060+
const TKqpSettings::TConstPtr& kqpSettings, TIntrusivePtr<TModuleResolverState> moduleResolverState, TIntrusivePtr<TKqpCounters> counters,
10641061
std::shared_ptr<IQueryReplayBackendFactory> queryReplayFactory,
10651062
std::optional<TKqpFederatedQuerySetup> federatedQuerySetup
10661063
)
10671064
{
1068-
return new TKqpCompileService(tableServiceConfig, queryServiceConfig, metadataProviderConfig, kqpSettings, moduleResolverState, counters,
1065+
return new TKqpCompileService(tableServiceConfig, queryServiceConfig, kqpSettings, moduleResolverState, counters,
10691066
std::move(queryReplayFactory), federatedQuerySetup);
10701067
}
10711068

‎ydb/core/kqp/compile_service/kqp_compile_service.h

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,6 @@ enum class ECompileActorAction {
1515

1616
IActor* CreateKqpCompileService(const NKikimrConfig::TTableServiceConfig& tableServiceConfig,
1717
const NKikimrConfig::TQueryServiceConfig& queryServiceConfig,
18-
const NKikimrConfig::TMetadataProviderConfig& metadataProviderConfig,
1918
const TKqpSettings::TConstPtr& kqpSettings, TIntrusivePtr<TModuleResolverState> moduleResolverState,
2019
TIntrusivePtr<TKqpCounters> counters, std::shared_ptr<IQueryReplayBackendFactory> queryReplayFactory,
2120
std::optional<TKqpFederatedQuerySetup> federatedQuerySetup
@@ -27,7 +26,6 @@ IActor* CreateKqpCompileComputationPatternService(const NKikimrConfig::TTableSer
2726
IActor* CreateKqpCompileActor(const TActorId& owner, const TKqpSettings::TConstPtr& kqpSettings,
2827
const NKikimrConfig::TTableServiceConfig& tableServiceConfig,
2928
const NKikimrConfig::TQueryServiceConfig& queryServiceConfig,
30-
const NKikimrConfig::TMetadataProviderConfig& metadataProviderConfig,
3129
TIntrusivePtr<TModuleResolverState> moduleResolverState, TIntrusivePtr<TKqpCounters> counters,
3230
const TString& uid, const TKqpQueryId& query,
3331
const TIntrusiveConstPtr<NACLib::TUserToken>& userToken,

‎ydb/core/kqp/executer_actor/kqp_data_executer.cpp

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -127,10 +127,10 @@ class TKqpDataExecuter : public TKqpExecuterBase<TKqpDataExecuter, EExecType::Da
127127
NYql::NDq::IDqAsyncIoFactory::TPtr asyncIoFactory,
128128
const NKikimrConfig::TTableServiceConfig::EChannelTransportVersion chanTransportVersion,
129129
const NKikimrConfig::TTableServiceConfig::TAggregationConfig& aggregation,
130-
const TActorId& creator, TDuration maximalSecretsSnapshotWaitTime, const TIntrusivePtr<TUserRequestContext>& userRequestContext,
130+
const TActorId& creator, const TIntrusivePtr<TUserRequestContext>& userRequestContext,
131131
const bool enableOlapSink)
132132
: TBase(std::move(request), database, userToken, counters, executerRetriesConfig, chanTransportVersion, aggregation,
133-
maximalSecretsSnapshotWaitTime, userRequestContext, TWilsonKqp::DataExecuter, "DataExecuter", streamResult
133+
userRequestContext, TWilsonKqp::DataExecuter, "DataExecuter", streamResult
134134
)
135135
, AsyncIoFactory(std::move(asyncIoFactory))
136136
, EnableOlapSink(enableOlapSink)
@@ -2442,10 +2442,10 @@ IActor* CreateKqpDataExecuter(IKqpGateway::TExecPhysicalRequest&& request, const
24422442
TKqpRequestCounters::TPtr counters, bool streamResult, const NKikimrConfig::TTableServiceConfig::TAggregationConfig& aggregation,
24432443
const NKikimrConfig::TTableServiceConfig::TExecuterRetriesConfig& executerRetriesConfig,
24442444
NYql::NDq::IDqAsyncIoFactory::TPtr asyncIoFactory, const NKikimrConfig::TTableServiceConfig::EChannelTransportVersion chanTransportVersion, const TActorId& creator,
2445-
TDuration maximalSecretsSnapshotWaitTime, const TIntrusivePtr<TUserRequestContext>& userRequestContext, const bool enableOlapSink)
2445+
const TIntrusivePtr<TUserRequestContext>& userRequestContext, const bool enableOlapSink)
24462446
{
24472447
return new TKqpDataExecuter(std::move(request), database, userToken, counters, streamResult, executerRetriesConfig,
2448-
std::move(asyncIoFactory), chanTransportVersion, aggregation, creator, maximalSecretsSnapshotWaitTime, userRequestContext, enableOlapSink);
2448+
std::move(asyncIoFactory), chanTransportVersion, aggregation, creator, userRequestContext, enableOlapSink);
24492449
}
24502450

24512451
} // namespace NKqp

‎ydb/core/kqp/executer_actor/kqp_executer.h

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -99,7 +99,7 @@ IActor* CreateKqpExecuter(IKqpGateway::TExecPhysicalRequest&& request, const TSt
9999
const NKikimrConfig::TTableServiceConfig::TExecuterRetriesConfig& executerRetriesConfig,
100100
NYql::NDq::IDqAsyncIoFactory::TPtr asyncIoFactory, TPreparedQueryHolder::TConstPtr preparedQuery,
101101
const NKikimrConfig::TTableServiceConfig::EChannelTransportVersion chanTransportVersion, const TActorId& creator,
102-
TDuration maximalSecretsSnapshotWaitTime, const TIntrusivePtr<TUserRequestContext>& userRequestContext,
102+
const TIntrusivePtr<TUserRequestContext>& userRequestContext,
103103
const bool enableOlapSink);
104104

105105
IActor* CreateKqpSchemeExecuter(

‎ydb/core/kqp/executer_actor/kqp_executer_impl.cpp

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -83,13 +83,13 @@ IActor* CreateKqpExecuter(IKqpGateway::TExecPhysicalRequest&& request, const TSt
8383
const NKikimrConfig::TTableServiceConfig::TExecuterRetriesConfig& executerRetriesConfig,
8484
NYql::NDq::IDqAsyncIoFactory::TPtr asyncIoFactory, TPreparedQueryHolder::TConstPtr preparedQuery,
8585
const NKikimrConfig::TTableServiceConfig::EChannelTransportVersion chanTransportVersion, const TActorId& creator,
86-
TDuration maximalSecretsSnapshotWaitTime, const TIntrusivePtr<TUserRequestContext>& userRequestContext,
86+
const TIntrusivePtr<TUserRequestContext>& userRequestContext,
8787
const bool enableOlapSink)
8888
{
8989
if (request.Transactions.empty()) {
9090
// commit-only or rollback-only data transaction
9191
YQL_ENSURE(request.LocksOp == ELocksOp::Commit || request.LocksOp == ELocksOp::Rollback);
92-
return CreateKqpDataExecuter(std::move(request), database, userToken, counters, false, aggregation, executerRetriesConfig, std::move(asyncIoFactory), chanTransportVersion, creator, maximalSecretsSnapshotWaitTime, userRequestContext, enableOlapSink);
92+
return CreateKqpDataExecuter(std::move(request), database, userToken, counters, false, aggregation, executerRetriesConfig, std::move(asyncIoFactory), chanTransportVersion, creator, userRequestContext, enableOlapSink);
9393
}
9494

9595
TMaybe<NKqpProto::TKqpPhyTx::EType> txsType;
@@ -107,13 +107,13 @@ IActor* CreateKqpExecuter(IKqpGateway::TExecPhysicalRequest&& request, const TSt
107107
switch (*txsType) {
108108
case NKqpProto::TKqpPhyTx::TYPE_COMPUTE:
109109
case NKqpProto::TKqpPhyTx::TYPE_DATA:
110-
return CreateKqpDataExecuter(std::move(request), database, userToken, counters, false, aggregation, executerRetriesConfig, std::move(asyncIoFactory), chanTransportVersion, creator, maximalSecretsSnapshotWaitTime, userRequestContext, enableOlapSink);
110+
return CreateKqpDataExecuter(std::move(request), database, userToken, counters, false, aggregation, executerRetriesConfig, std::move(asyncIoFactory), chanTransportVersion, creator, userRequestContext, enableOlapSink);
111111

112112
case NKqpProto::TKqpPhyTx::TYPE_SCAN:
113-
return CreateKqpScanExecuter(std::move(request), database, userToken, counters, aggregation, executerRetriesConfig, preparedQuery, chanTransportVersion, maximalSecretsSnapshotWaitTime, userRequestContext);
113+
return CreateKqpScanExecuter(std::move(request), database, userToken, counters, aggregation, executerRetriesConfig, preparedQuery, chanTransportVersion, userRequestContext);
114114

115115
case NKqpProto::TKqpPhyTx::TYPE_GENERIC:
116-
return CreateKqpDataExecuter(std::move(request), database, userToken, counters, true, aggregation, executerRetriesConfig, std::move(asyncIoFactory), chanTransportVersion, creator, maximalSecretsSnapshotWaitTime, userRequestContext, enableOlapSink);
116+
return CreateKqpDataExecuter(std::move(request), database, userToken, counters, true, aggregation, executerRetriesConfig, std::move(asyncIoFactory), chanTransportVersion, creator, userRequestContext, enableOlapSink);
117117

118118
default:
119119
YQL_ENSURE(false, "Unsupported physical tx type: " << (ui32)*txsType);

‎ydb/core/kqp/executer_actor/kqp_executer_impl.h

Lines changed: 4 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -126,7 +126,7 @@ class TKqpExecuterBase : public TActorBootstrapped<TDerived> {
126126
const NKikimrConfig::TTableServiceConfig::TExecuterRetriesConfig& executerRetriesConfig,
127127
const NKikimrConfig::TTableServiceConfig::EChannelTransportVersion chanTransportVersion,
128128
const NKikimrConfig::TTableServiceConfig::TAggregationConfig& aggregation,
129-
TDuration maximalSecretsSnapshotWaitTime, const TIntrusivePtr<TUserRequestContext>& userRequestContext,
129+
const TIntrusivePtr<TUserRequestContext>& userRequestContext,
130130
ui64 spanVerbosity = 0, TString spanName = "KqpExecuterBase", bool streamResult = false)
131131
: Request(std::move(request))
132132
, Database(database)
@@ -135,7 +135,6 @@ class TKqpExecuterBase : public TActorBootstrapped<TDerived> {
135135
, ExecuterSpan(spanVerbosity, std::move(Request.TraceId), spanName)
136136
, Planner(nullptr)
137137
, ExecuterRetriesConfig(executerRetriesConfig)
138-
, MaximalSecretsSnapshotWaitTime(maximalSecretsSnapshotWaitTime)
139138
, AggregationSettings(aggregation)
140139
, HasOlapTable(false)
141140
, StreamResult(streamResult)
@@ -1598,7 +1597,7 @@ class TKqpExecuterBase : public TActorBootstrapped<TDerived> {
15981597
}
15991598

16001599
void GetSecretsSnapshot() {
1601-
RegisterDescribeSecretsActor(this->SelfId(), UserToken ? UserToken->GetUserSID() : "", SecretNames, this->ActorContext().ActorSystem(), MaximalSecretsSnapshotWaitTime);
1600+
RegisterDescribeSecretsActor(this->SelfId(), UserToken ? UserToken->GetUserSID() : "", SecretNames, this->ActorContext().ActorSystem());
16021601
}
16031602

16041603
void GetResourcesSnapshot() {
@@ -1924,7 +1923,6 @@ class TKqpExecuterBase : public TActorBootstrapped<TDerived> {
19241923

19251924
std::vector<TString> SecretNames;
19261925
std::map<TString, TString> SecureParams;
1927-
TDuration MaximalSecretsSnapshotWaitTime;
19281926

19291927
const NKikimrConfig::TTableServiceConfig::TAggregationConfig AggregationSettings;
19301928
TVector<NKikimrKqp::TKqpNodeResources> ResourcesSnapshot;
@@ -1950,15 +1948,15 @@ IActor* CreateKqpDataExecuter(IKqpGateway::TExecPhysicalRequest&& request, const
19501948
const NKikimrConfig::TTableServiceConfig::TExecuterRetriesConfig& executerRetriesConfig,
19511949
NYql::NDq::IDqAsyncIoFactory::TPtr asyncIoFactory,
19521950
const NKikimrConfig::TTableServiceConfig::EChannelTransportVersion chanTransportVersion, const TActorId& creator,
1953-
TDuration maximalSecretsSnapshotWaitTime, const TIntrusivePtr<TUserRequestContext>& userRequestContext,
1951+
const TIntrusivePtr<TUserRequestContext>& userRequestContext,
19541952
const bool enableOlapSink);
19551953

19561954
IActor* CreateKqpScanExecuter(IKqpGateway::TExecPhysicalRequest&& request, const TString& database,
19571955
const TIntrusiveConstPtr<NACLib::TUserToken>& userToken, TKqpRequestCounters::TPtr counters,
19581956
const NKikimrConfig::TTableServiceConfig::TAggregationConfig& aggregation,
19591957
const NKikimrConfig::TTableServiceConfig::TExecuterRetriesConfig& executerRetriesConfig,
19601958
TPreparedQueryHolder::TConstPtr preparedQuery, const NKikimrConfig::TTableServiceConfig::EChannelTransportVersion chanTransportVersion,
1961-
TDuration maximalSecretsSnapshotWaitTime, const TIntrusivePtr<TUserRequestContext>& userRequestContext);
1959+
const TIntrusivePtr<TUserRequestContext>& userRequestContext);
19621960

19631961
} // namespace NKqp
19641962
} // namespace NKikimr

‎ydb/core/kqp/executer_actor/kqp_scan_executer.cpp

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -49,9 +49,9 @@ class TKqpScanExecuter : public TKqpExecuterBase<TKqpScanExecuter, EExecType::Sc
4949
const NKikimrConfig::TTableServiceConfig::TExecuterRetriesConfig& executerRetriesConfig,
5050
TPreparedQueryHolder::TConstPtr preparedQuery,
5151
const NKikimrConfig::TTableServiceConfig::EChannelTransportVersion chanTransportVersion,
52-
TDuration maximalSecretsSnapshotWaitTime, const TIntrusivePtr<TUserRequestContext>& userRequestContext)
52+
const TIntrusivePtr<TUserRequestContext>& userRequestContext)
5353
: TBase(std::move(request), database, userToken, counters, executerRetriesConfig, chanTransportVersion, aggregation,
54-
maximalSecretsSnapshotWaitTime, userRequestContext, TWilsonKqp::ScanExecuter, "ScanExecuter",
54+
userRequestContext, TWilsonKqp::ScanExecuter, "ScanExecuter",
5555
false
5656
)
5757
, PreparedQuery(preparedQuery)
@@ -367,10 +367,10 @@ IActor* CreateKqpScanExecuter(IKqpGateway::TExecPhysicalRequest&& request, const
367367
const NKikimrConfig::TTableServiceConfig::TAggregationConfig& aggregation,
368368
const NKikimrConfig::TTableServiceConfig::TExecuterRetriesConfig& executerRetriesConfig,
369369
TPreparedQueryHolder::TConstPtr preparedQuery, const NKikimrConfig::TTableServiceConfig::EChannelTransportVersion chanTransportVersion,
370-
TDuration maximalSecretsSnapshotWaitTime, const TIntrusivePtr<TUserRequestContext>& userRequestContext)
370+
const TIntrusivePtr<TUserRequestContext>& userRequestContext)
371371
{
372372
return new TKqpScanExecuter(std::move(request), database, userToken, counters, aggregation, executerRetriesConfig,
373-
preparedQuery, chanTransportVersion, maximalSecretsSnapshotWaitTime, userRequestContext);
373+
preparedQuery, chanTransportVersion, userRequestContext);
374374
}
375375

376376
} // namespace NKqp

0 commit comments

Comments
 (0)