aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorandrewproni <andrewproni@yandex-team.com>2023-07-24 20:28:58 +0300
committerandrewproni <andrewproni@yandex-team.com>2023-07-24 20:28:58 +0300
commitf8d40d044d6915bedeb820476ecb1dc44c364cdf (patch)
tree175d1dc73f71f5cf531f58d5676d5e1c6f84a4f4
parente976914ac18c28b062fc522b7d305c0c167cb83d (diff)
downloadydb-f8d40d044d6915bedeb820476ecb1dc44c364cdf.tar.gz
KIKIMR-18737: RunScriptActor Fix
-rw-r--r--ydb/core/kqp/proxy_service/kqp_script_executions.cpp2
-rw-r--r--ydb/core/kqp/run_script_actor/kqp_run_script_actor.cpp1
2 files changed, 2 insertions, 1 deletions
diff --git a/ydb/core/kqp/proxy_service/kqp_script_executions.cpp b/ydb/core/kqp/proxy_service/kqp_script_executions.cpp
index b5f1620ce3..66693d4d92 100644
--- a/ydb/core/kqp/proxy_service/kqp_script_executions.cpp
+++ b/ydb/core/kqp/proxy_service/kqp_script_executions.cpp
@@ -1435,7 +1435,7 @@ public:
}
void OnFinish(Ydb::StatusIds::StatusCode status, NYql::TIssues&& issues) override {
- if (status == Ydb::StatusIds::SUCCESS || status == Ydb::StatusIds::ABORTED && LeaseExpired) {
+ if (status == Ydb::StatusIds::SUCCESS) {
TMaybe<google::protobuf::Any> metadata;
metadata.ConstructInPlace().PackFrom(Metadata);
diff --git a/ydb/core/kqp/run_script_actor/kqp_run_script_actor.cpp b/ydb/core/kqp/run_script_actor/kqp_run_script_actor.cpp
index a124b79d52..69315beca5 100644
--- a/ydb/core/kqp/run_script_actor/kqp_run_script_actor.cpp
+++ b/ydb/core/kqp/run_script_actor/kqp_run_script_actor.cpp
@@ -167,6 +167,7 @@ private:
FinalStatusIsSaved = true;
Register(CreateScriptExecutionFinisher(ExecutionId, Database, LeaseGeneration, Status, GetExecStatusFromStatusCode(Status),
Issues, std::move(QueryStats), std::move(QueryPlan), std::move(QueryAst)));
+ return;
}
if (RunState != ERunState::Cancelled && RunState != ERunState::Finished) {