From 818acdddcd3bdf0bd603c32a13929a546e7044a0 Mon Sep 17 00:00:00 2001 From: Oleg Ovcharuk Date: Thu, 6 Feb 2025 18:22:19 +0300 Subject: [PATCH] remove default values from proto DTO --- ydb/_grpc/grpcwrapper/ydb_topic.py | 2 +- ydb/_topic_reader/topic_reader_asyncio_test.py | 1 + 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/ydb/_grpc/grpcwrapper/ydb_topic.py b/ydb/_grpc/grpcwrapper/ydb_topic.py index 4e23d370..600dfb69 100644 --- a/ydb/_grpc/grpcwrapper/ydb_topic.py +++ b/ydb/_grpc/grpcwrapper/ydb_topic.py @@ -419,7 +419,7 @@ def from_proto( class InitRequest(IToProto): topics_read_settings: List["StreamReadMessage.InitRequest.TopicReadSettings"] consumer: str - auto_partitioning_support: bool = False + auto_partitioning_support: bool def to_proto(self) -> ydb_topic_pb2.StreamReadMessage.InitRequest: res = ydb_topic_pb2.StreamReadMessage.InitRequest() diff --git a/ydb/_topic_reader/topic_reader_asyncio_test.py b/ydb/_topic_reader/topic_reader_asyncio_test.py index c598d1ce..7ad5077c 100644 --- a/ydb/_topic_reader/topic_reader_asyncio_test.py +++ b/ydb/_topic_reader/topic_reader_asyncio_test.py @@ -610,6 +610,7 @@ async def test_init_reader(self, stream, default_reader_settings): read_from=None, ) ], + auto_partitioning_support=False, ) start_task = asyncio.create_task(reader._start(stream, init_message))