Skip to content

Commit c7c84d0

Browse files
Merge e18c0a3 into ad9481c
2 parents ad9481c + e18c0a3 commit c7c84d0

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

ydb/core/kqp/session_actor/kqp_session_actor.cpp

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2276,6 +2276,10 @@ class TKqpSessionActor : public TActorBootstrapped<TKqpSessionActor> {
22762276
PassAway();
22772277
}
22782278

2279+
void HandleFinalCleanup(TEvKqp::TEvQueryRequest::TPtr& ev) {
2280+
ReplyProcessError(ev->Sender, ev->Cookie, Ydb::StatusIds::BAD_SESSION, "Session is under shutdown");
2281+
}
2282+
22792283
STFUNC(ReadyState) {
22802284
try {
22812285
switch (ev->GetTypeRewrite()) {
@@ -2407,6 +2411,7 @@ class TKqpSessionActor : public TActorBootstrapped<TKqpSessionActor> {
24072411
hFunc(TEvents::TEvUndelivered, HandleNoop);
24082412
hFunc(TEvKqpSnapshot::TEvCreateSnapshotResponse, Handle);
24092413
hFunc(NWorkload::TEvContinueRequest, HandleNoop);
2414+
hFunc(TEvKqp::TEvQueryRequest, HandleFinalCleanup);
24102415
}
24112416
} catch (const yexception& ex) {
24122417
InternalError(ex.what());

0 commit comments

Comments
 (0)