Intermediate changes

commit_hash:ea6617380efc5fd86784a19436fefccb22019756

5 files changed, 35 insertions, 4 deletions

diff --git a/contrib/python/ydb/py3/.dist-info/METADATA b/contrib/python/ydb/py3/.dist-info/METADATA
index bf88c2eae95..b6911ce75e8 100644
--- a/contrib/python/ydb/py3/.dist-info/METADATA
+++ b/contrib/python/ydb/py3/.dist-info/METADATA
@@ -1,6 +1,6 @@
 Metadata-Version: 2.1
 Name: ydb
-Version: 3.19.2
+Version: 3.19.3
 Summary: YDB Python SDK
 Home-page: http://github.com/ydb-platform/ydb-python-sdk
 Author: Yandex LLC
diff --git a/contrib/python/ydb/py3/ya.make b/contrib/python/ydb/py3/ya.make
index 5b1a93f20f2..71cfb8fa720 100644
--- a/contrib/python/ydb/py3/ya.make
+++ b/contrib/python/ydb/py3/ya.make
@@ -2,7 +2,7 @@
 
 PY3_LIBRARY()
 
-VERSION(3.19.2)
+VERSION(3.19.3)
 
 LICENSE(Apache-2.0)
 
diff --git a/contrib/python/ydb/py3/ydb/_grpc/grpcwrapper/ydb_topic.py b/contrib/python/ydb/py3/ydb/_grpc/grpcwrapper/ydb_topic.py
index d1872f4245f..5b22c7cf862 100644
--- a/contrib/python/ydb/py3/ydb/_grpc/grpcwrapper/ydb_topic.py
+++ b/contrib/python/ydb/py3/ydb/_grpc/grpcwrapper/ydb_topic.py
@@ -906,10 +906,11 @@ class Consumer(IToProto, IFromProto, IFromPublic, IToPublic):
             read_from=self.read_from,
             supported_codecs=self.supported_codecs.to_public(),
             attributes=self.attributes,
+            consumer_stats=self.consumer_stats.to_public(),
         )
 
     @dataclass
-    class ConsumerStats(IFromProto):
+    class ConsumerStats(IFromProto, IToPublic):
         min_partitions_last_read_time: datetime.datetime
         max_read_time_lag: datetime.timedelta
         max_write_time_lag: datetime.timedelta
@@ -926,6 +927,14 @@ class Consumer(IToProto, IFromProto, IFromPublic, IToPublic):
                 bytes_read=MultipleWindowsStat.from_proto(msg.bytes_read),
             )
 
+        def to_public(self) -> ydb_topic_public_types.PublicConsumer.ConsumerStats:
+            return ydb_topic_public_types.PublicConsumer.ConsumerStats(
+                min_partitions_last_read_time=self.min_partitions_last_read_time,
+                max_read_time_lag=self.max_read_time_lag,
+                max_write_time_lag=self.max_write_time_lag,
+                bytes_read=self.bytes_read,
+            )
+
 
 @dataclass
 class AlterConsumer(IToProto, IFromPublic):
diff --git a/contrib/python/ydb/py3/ydb/_grpc/grpcwrapper/ydb_topic_public_types.py b/contrib/python/ydb/py3/ydb/_grpc/grpcwrapper/ydb_topic_public_types.py
index e3b118e9ca2..388b47a8f79 100644
--- a/contrib/python/ydb/py3/ydb/_grpc/grpcwrapper/ydb_topic_public_types.py
+++ b/contrib/python/ydb/py3/ydb/_grpc/grpcwrapper/ydb_topic_public_types.py
@@ -116,6 +116,28 @@ class PublicConsumer:
     attributes: Dict[str, str] = field(default_factory=lambda: dict())
     "Attributes of consumer"
 
+    consumer_stats: Optional["PublicConsumer.ConsumerStats"] = None
+
+    @dataclass
+    class ConsumerStats:
+        min_partitions_last_read_time: datetime.datetime
+        "Minimal timestamp of last read from partitions."
+
+        max_read_time_lag: datetime.timedelta
+        """
+        Maximum of differences between timestamp of read and write timestamp for all messages,
+        read during last minute.
+        """
+
+        max_write_time_lag: datetime.timedelta
+        """
+        Maximum of differences between write timestamp and create timestamp for all messages,
+        written during last minute.
+        """
+
+        bytes_read: "PublicMultipleWindowsStat"
+        "Bytes read statistics."
+
 
 @dataclass
 class PublicAlterConsumer:
diff --git a/contrib/python/ydb/py3/ydb/ydb_version.py b/contrib/python/ydb/py3/ydb/ydb_version.py
index b3fbda15002..8bd658d49e4 100644
--- a/contrib/python/ydb/py3/ydb/ydb_version.py
+++ b/contrib/python/ydb/py3/ydb/ydb_version.py
@@ -1 +1 @@
-VERSION = "3.19.2"
+VERSION = "3.19.3"