Fixed performance

Author: GrigoriyPA

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

@@ -24,7 +24,6 @@ struct TEvPlaceRequestIntoPool : public NActors::TEventLocal<TEvPlaceRequestInto
     const TString SessionId;
     TString PoolId;  // Can be changed to default pool id
     TIntrusiveConstPtr<NACLib::TUserToken> UserToken;
-    bool FromCache = false;
 };
 
 struct TEvContinueRequest : public NActors::TEventLocal<TEvContinueRequest, TKqpWorkloadServiceEvents::EvContinueRequest> {

ydb/core/kqp/session_actor/kqp_session_actor.cpp

@@ -242,20 +242,20 @@ class TKqpSessionActor : public TActorBootstrapped<TKqpSessionActor> {
     }
 
     void PassRequestToResourcePool() {
-        const TString& poolId = QueryState->UserRequestContext->PoolId;
-        auto event = std::make_unique<NWorkload::TEvPlaceRequestIntoPool>(QueryState->Database, SessionId, poolId, QueryState->UserToken);
-
-        TEventFlags flags = 0;
         if (QueryState->UserRequestContext->PoolConfig) {
-            LOG_D("request placed into pool from cache: " << poolId);
-            event->FromCache = true;
+            LOG_D("request placed into pool from cache: " << QueryState->UserRequestContext->PoolId);
             CompileQuery();
-        } else {
-            flags |= IEventHandle::FlagTrackDelivery;
-            Become(&TKqpSessionActor::ExecuteState);
+            return;
         }
 
-        Send(MakeKqpWorkloadServiceId(SelfId().NodeId()), event.release(), flags);
+        Send(MakeKqpWorkloadServiceId(SelfId().NodeId()), new NWorkload::TEvPlaceRequestIntoPool(
+            QueryState->Database,
+            SessionId,
+            QueryState->UserRequestContext->PoolId,
+            QueryState->UserToken
+        ), IEventHandle::FlagTrackDelivery);
+
+        Become(&TKqpSessionActor::ExecuteState);
     }
 
     void ForwardRequest(TEvKqp::TEvQueryRequest::TPtr& ev) {