Skip to content

Commit 8f49fdd

Browse files
Alek5andr-Kotovzinal
authored andcommitted
Tests TxUsage::WriteToTopic_Invalid_* (ydb-platform#12475)
1 parent b47cdc0 commit 8f49fdd

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
@@ -2275,6 +2275,10 @@ class TKqpSessionActor : public TActorBootstrapped<TKqpSessionActor> {
22752275
PassAway();
22762276
}
22772277

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

0 commit comments

Comments
 (0)