diff options
| author | Daniil Cherednik <dcherednik@yandex-team.ru> | 2023-12-19 11:33:59 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2023-12-19 13:33:59 +0300 |
| commit | cbc404bef30b4b349b0237f180ebb0ef8bc00ba6 (patch) | |
| tree | 31e96fca42c12e94bb268d59af1764c1a6802420 | |
| parent | f85c76d7da365e53f78b139ec8a76b04bf3b8260 (diff) | |
| download | ydb-cbc404bef30b4b349b0237f180ebb0ef8bc00ba6.tar.gz | |
Fix missed subscription for non local request cancelation. (#527)
| -rw-r--r-- | ydb/core/grpc_services/query/rpc_execute_query.cpp | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/ydb/core/grpc_services/query/rpc_execute_query.cpp b/ydb/core/grpc_services/query/rpc_execute_query.cpp index 7d42cd21f82..c5860551eef 100644 --- a/ydb/core/grpc_services/query/rpc_execute_query.cpp +++ b/ydb/core/grpc_services/query/rpc_execute_query.cpp @@ -211,7 +211,7 @@ private: HFunc(TRpcServices::TEvGrpcNextReply, Handle); HFunc(NKqp::TEvKqpExecuter::TEvStreamData, Handle); HFunc(NKqp::TEvKqp::TEvQueryResponse, Handle); - HFunc(NKikimr::NGRpcService::TEvSubscribeGrpcCancel, Handle); + hFunc(NKikimr::NGRpcService::TEvSubscribeGrpcCancel, Handle); default: UnexpectedEvent(__func__, ev); } @@ -278,8 +278,9 @@ private: } } - void Handle(NKikimr::NGRpcService::TEvSubscribeGrpcCancel::TPtr&, const TActorContext&) { - // Ignore event now + void Handle(NKikimr::NGRpcService::TEvSubscribeGrpcCancel::TPtr& ev) { + auto as = TActivationContext::ActorSystem(); + PassSubscription(ev->Get(), Request_.get(), as); } void Handle(TEvents::TEvWakeup::TPtr& ev, const TActorContext& ctx) { |