aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authordcherednik <dcherednik@ydb.tech>2023-07-13 16:40:11 +0300
committerdcherednik <dcherednik@ydb.tech>2023-07-13 16:40:11 +0300
commit6de7fc0cd1c34f1e38b314eb169e4508a13ec3c3 (patch)
tree8e4b15cdb11c9cd802cea5038cf30a77bcd49d51
parent0a47ca40422ba3f6d58deb4f11f9ed46b1d27e5d (diff)
downloadydb-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.cpp4
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);
}
}