File tree Expand file tree Collapse file tree 1 file changed +13
-13
lines changed Expand file tree Collapse file tree 1 file changed +13
-13
lines changed Original file line number Diff line number Diff line change @@ -32,19 +32,6 @@ class Codec(IntEnum):
3232 CODEC_ZSTD = 4
3333
3434
35- @dataclass
36- class OffsetsRange (IFromProto ):
37- start : int
38- end : int
39-
40- @staticmethod
41- def from_proto (msg : ydb_topic_pb2 .OffsetsRange ) -> "OffsetsRange" :
42- return OffsetsRange (
43- start = msg .start ,
44- end = msg .end ,
45- )
46-
47-
4835class IToProto (abc .ABC ):
4936 @abc .abstractmethod
5037 def to_proto (self ) -> Message :
@@ -62,6 +49,19 @@ def from_proto(msg: Message) -> typing.Any:
6249 pass
6350
6451
52+ @dataclass
53+ class OffsetsRange (IFromProto ):
54+ start : int
55+ end : int
56+
57+ @staticmethod
58+ def from_proto (msg : ydb_topic_pb2 .OffsetsRange ) -> "OffsetsRange" :
59+ return OffsetsRange (
60+ start = msg .start ,
61+ end = msg .end ,
62+ )
63+
64+
6565class QueueToIteratorAsyncIO :
6666 __slots__ = ("_queue" ,)
6767
You can’t perform that action at this time.
0 commit comments