diff options
author | andrewproni <andrewproni@yandex-team.com> | 2023-07-24 20:28:58 +0300 |
---|---|---|
committer | andrewproni <andrewproni@yandex-team.com> | 2023-07-24 20:28:58 +0300 |
commit | f8d40d044d6915bedeb820476ecb1dc44c364cdf (patch) | |
tree | 175d1dc73f71f5cf531f58d5676d5e1c6f84a4f4 | |
parent | e976914ac18c28b062fc522b7d305c0c167cb83d (diff) | |
download | ydb-f8d40d044d6915bedeb820476ecb1dc44c364cdf.tar.gz |
KIKIMR-18737: RunScriptActor Fix
-rw-r--r-- | ydb/core/kqp/proxy_service/kqp_script_executions.cpp | 2 | ||||
-rw-r--r-- | ydb/core/kqp/run_script_actor/kqp_run_script_actor.cpp | 1 |
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) { |