File tree Expand file tree Collapse file tree 1 file changed +14
-0
lines changed Expand file tree Collapse file tree 1 file changed +14
-0
lines changed Original file line number Diff line number Diff line change @@ -696,6 +696,20 @@ def to_proto(self) -> ydb_topic_pb2.StreamReadMessage.StopPartitionSessionRespon
696
696
partition_session_id = self .partition_session_id ,
697
697
)
698
698
699
+ @dataclass
700
+ class EndPartitionSession (IFromProto ):
701
+ partition_session_id : int
702
+ adjacent_partition_ids : List [int ]
703
+ child_partition_ids : List [int ]
704
+
705
+ @staticmethod
706
+ def from_proto (msg : ydb_topic_pb2 .StreamReadMessage .EndPartitionSession ):
707
+ return StreamReadMessage .EndPartitionSession (
708
+ partition_session_id = msg .partition_session_id ,
709
+ adjacent_partition_ids = list (msg .adjacent_partition_ids ),
710
+ child_partition_ids = list (msg .child_partition_ids ),
711
+ )
712
+
699
713
@dataclass
700
714
class FromClient (IToProto ):
701
715
client_message : "ReaderMessagesFromClientToServer"
You can’t perform that action at this time.
0 commit comments