diff options
author | dcherednik <dcherednik@ydb.tech> | 2023-07-13 16:40:11 +0300 |
---|---|---|
committer | dcherednik <dcherednik@ydb.tech> | 2023-07-13 16:40:11 +0300 |
commit | 6de7fc0cd1c34f1e38b314eb169e4508a13ec3c3 (patch) | |
tree | 8e4b15cdb11c9cd802cea5038cf30a77bcd49d51 | |
parent | 0a47ca40422ba3f6d58deb4f11f9ed46b1d27e5d (diff) | |
download | ydb-6de7fc0cd1c34f1e38b314eb169e4508a13ec3c3.tar.gz |
Use CANCELED status in case of compilation timeout if cancel after has been set. KIKIMR-18698
-rw-r--r-- | ydb/core/kqp/session_actor/kqp_session_actor.cpp | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/ydb/core/kqp/session_actor/kqp_session_actor.cpp b/ydb/core/kqp/session_actor/kqp_session_actor.cpp index 7e5fedd18c..d6b74dcede 100644 --- a/ydb/core/kqp/session_actor/kqp_session_actor.cpp +++ b/ydb/core/kqp/session_actor/kqp_session_actor.cpp @@ -1507,6 +1507,10 @@ public: const auto& phyQuery = QueryState->PreparedQuery->GetPhysicalQuery(); FillColumnsMeta(phyQuery, response); + } else if (compileResult->Status == Ydb::StatusIds::TIMEOUT && QueryState->QueryDeadlines.CancelAt) { + // The compile timeout cause cancelation execution of request. + // So in case of cancel after we can reply with canceled status + ev.SetYdbStatus(Ydb::StatusIds::CANCELLED); } } |