Skip to content

Commit 8d4aa78

Browse files
committed
Fix missed subscription for non local request cancelation.
1 parent b9f3120 commit 8d4aa78

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

ydb/core/grpc_services/query/rpc_execute_query.cpp

+4-3
Original file line numberDiff line numberDiff line change
@@ -211,7 +211,7 @@ class TExecuteQueryRPC : public TActorBootstrapped<TExecuteQueryRPC> {
211211
HFunc(TRpcServices::TEvGrpcNextReply, Handle);
212212
HFunc(NKqp::TEvKqpExecuter::TEvStreamData, Handle);
213213
HFunc(NKqp::TEvKqp::TEvQueryResponse, Handle);
214-
HFunc(NKikimr::NGRpcService::TEvSubscribeGrpcCancel, Handle);
214+
hFunc(NKikimr::NGRpcService::TEvSubscribeGrpcCancel, Handle);
215215
default:
216216
UnexpectedEvent(__func__, ev);
217217
}
@@ -278,8 +278,9 @@ class TExecuteQueryRPC : public TActorBootstrapped<TExecuteQueryRPC> {
278278
}
279279
}
280280

281-
void Handle(NKikimr::NGRpcService::TEvSubscribeGrpcCancel::TPtr&, const TActorContext&) {
282-
// Ignore event now
281+
void Handle(NKikimr::NGRpcService::TEvSubscribeGrpcCancel::TPtr& ev) {
282+
auto as = TActivationContext::ActorSystem();
283+
PassSubscription(ev->Get(), Request_.get(), as);
283284
}
284285

285286
void Handle(TEvents::TEvWakeup::TPtr& ev, const TActorContext& ctx) {

0 commit comments

Comments
 (0)