Removed send response on cleanup

Author: GrigoriyPA

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

@@ -51,21 +51,19 @@ struct TEvContinueRequest : public NActors::TEventLocal<TEvContinueRequest, TKqp
 };
 
 struct TEvCleanupRequest : public NActors::TEventLocal<TEvCleanupRequest, TKqpWorkloadServiceEvents::EvCleanupRequest> {
-    TEvCleanupRequest(const TString& database, const TString& sessionId, const TString& poolId, TDuration duration, TDuration cpuConsumed, bool sendResponseOnNotFound = true)
+    TEvCleanupRequest(const TString& database, const TString& sessionId, const TString& poolId, TDuration duration, TDuration cpuConsumed)
         : Database(database)
         , SessionId(sessionId)
         , PoolId(poolId)
         , Duration(duration)
         , CpuConsumed(cpuConsumed)
-        , SendResponseOnNotFound(sendResponseOnNotFound)
     {}
 
     const TString Database;
     const TString SessionId;
     const TString PoolId;
     const TDuration Duration;
     const TDuration CpuConsumed;
-    bool SendResponseOnNotFound = true;
 };
 
 struct TEvCleanupResponse : public NActors::TEventLocal<TEvCleanupResponse, TKqpWorkloadServiceEvents::EvCleanupResponse> {

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

@@ -218,13 +218,7 @@ class TPoolHandlerActorBase : public TActor<TDerived> {
         const TActorId& workerActorId = ev->Sender;
 
         TRequest* request = GetRequestSafe(sessionId);
-        if (!request) {
-            if (ev->Get()->SendResponseOnNotFound) {
-                this->Send(workerActorId, new TEvCleanupResponse(Ydb::StatusIds::SUCCESS));
-            }
-            return;
-        }
-        if (request->State == TRequest::EState::Canceling) {
+        if (!request || request->State == TRequest::EState::Canceling) {
             this->Send(workerActorId, new TEvCleanupResponse(Ydb::StatusIds::SUCCESS));
             return;
         }

ydb/core/kqp/workload_service/kqp_workload_service_impl.h

@@ -161,11 +161,10 @@ 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, event->Get()->SendResponseOnNotFound
+                event->Get()->Duration, event->Get()->CpuConsumed
             ));
         }
         ActorContext.Send(event->Forward(PoolHandler));