@@ -51,7 +51,7 @@ struct TExecutionOptions {
51
51
}
52
52
53
53
for (size_t i = 0 ; i < ExecutionCases.size (); ++i) {
54
- if (i < ScriptQueryActions. size () && ScriptQueryActions[i] != NKikimrKqp::EQueryAction::QUERY_ACTION_EXECUTE) {
54
+ if (GetScriptQueryAction (i) != NKikimrKqp::EQueryAction::QUERY_ACTION_EXECUTE) {
55
55
continue ;
56
56
}
57
57
if (ExecutionCases[i] != EExecutionCase::AsyncQuery) {
@@ -65,6 +65,10 @@ struct TExecutionOptions {
65
65
return GetValue (index , ExecutionCases, EExecutionCase::GenericScript);
66
66
}
67
67
68
+ NKikimrKqp::EQueryAction GetScriptQueryAction (size_t index) const {
69
+ return GetValue (index , ScriptQueryActions, NKikimrKqp::EQueryAction::QUERY_ACTION_EXECUTE);
70
+ }
71
+
68
72
NKqpRun::TRequestOptions GetSchemeQueryOptions () const {
69
73
return {
70
74
.Query = SchemeQuery,
@@ -79,7 +83,7 @@ struct TExecutionOptions {
79
83
Y_ABORT_UNLESS (index < ScriptQueries.size ());
80
84
return {
81
85
.Query = ScriptQueries[index ],
82
- .Action = GetValue (index , ScriptQueryActions, NKikimrKqp::EQueryAction::QUERY_ACTION_EXECUTE ),
86
+ .Action = GetScriptQueryAction (index ),
83
87
.TraceId = TStringBuilder () << GetValue (index , TraceIds, DefaultTraceId) << " -" << startTime.ToString (),
84
88
.PoolId = GetValue (index , PoolIds, TString ()),
85
89
.UserSID = GetValue (index , UserSIDs, TString (BUILTIN_ACL_ROOT))
0 commit comments