Fixed typo

Author: GrigoriyPA

ydb/core/kqp/common/events/workload_service.h

@@ -57,15 +57,15 @@ struct TEvCleanupRequest : public NActors::TEventLocal<TEvCleanupRequest, TKqpWo
         , PoolId(poolId)
         , Duration(duration)
         , CpuConsumed(cpuConsumed)
-        , sendResponseOnNotFound(sendResponseOnNotFound)
+        , SendResponseOnNotFound(sendResponseOnNotFound)
     {}
 
     const TString Database;
     const TString SessionId;
     const TString PoolId;
     const TDuration Duration;
     const TDuration CpuConsumed;
-    const bool sendResponseOnNotFound;
+    bool SendResponseOnNotFound = true;
 };
 
 struct TEvCleanupResponse : public NActors::TEventLocal<TEvCleanupResponse, TKqpWorkloadServiceEvents::EvCleanupResponse> {

ydb/core/kqp/workload_service/actors/pool_handlers_acors.cpp

@@ -219,7 +219,7 @@ class TPoolHandlerActorBase : public TActor<TDerived> {
 
         TRequest* request = GetRequestSafe(sessionId);
         if (!request) {
-            if (ev->Get()->sendResponseOnNotFound) {
+            if (ev->Get()->SendResponseOnNotFound) {
                 this->Send(workerActorId, new TEvCleanupResponse(Ydb::StatusIds::SUCCESS));
             }
             return;

ydb/core/kqp/workload_service/kqp_workload_service.cpp

@@ -263,7 +263,6 @@ class TKqpWorkloadService : public TActorBootstrapped<TKqpWorkloadService> {
             databaseState->RemovePendingSession(event->Get()->SessionId, [this](TEvCleanupRequest::TPtr event) {
                 ReplyCleanupError(event->Sender, Ydb::StatusIds::NOT_FOUND, TStringBuilder() << "Pool " << event->Get()->PoolId << " not found");
             });
-            databaseState->PendingSessionIds.erase(event->Get()->SessionId);
             ReplyContinueError(event->Sender, ev->Get()->Status, ev->Get()->Issues);
             return;
         }

ydb/core/kqp/workload_service/kqp_workload_service_impl.h

@@ -161,10 +161,11 @@ struct TPoolState {
     }
 
     void DoCleanupRequest(TEvCleanupRequest::TPtr event) {
+        event->Get()->SendResponseOnNotFound = false;
         for (const auto& poolHandler : PreviousPoolHandlers) {
             ActorContext.Send(poolHandler, new TEvCleanupRequest(
                 event->Get()->Database, event->Get()->SessionId, event->Get()->PoolId,
-                event->Get()->Duration, event->Get()->CpuConsumed, false
+                event->Get()->Duration, event->Get()->CpuConsumed, event->Get()->SendResponseOnNotFound
             ));
         }
         ActorContext.Send(event->Forward(PoolHandler));