Skip to content

Commit e7ccd59

Browse files
authored
fix frozing of write session (#7958)
1 parent 34f01ca commit e7ccd59

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

ydb/core/persqueue/writer/partition_chooser_impl__old_chooser_actor.h

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -100,6 +100,7 @@ class TPartitionChooserActor: public TAbstractPartitionChooserActor<TPartitionCh
100100
TRACE_EVENT(NKikimrServices::PQ_PARTITION_CHOOSER);
101101
switch (ev->GetTypeRewrite()) {
102102
HFunc(TEvPersQueue::TEvGetPartitionIdForWriteResponse, Handle);
103+
HFunc(TEvTabletPipe::TEvClientConnected, Handle);
103104
HFunc(TEvTabletPipe::TEvClientDestroyed, Handle);
104105
SFunc(TEvents::TEvPoison, TThis::Die);
105106
}

0 commit comments

Comments
 (0)