diff --git a/ydb/_topic_reader/topic_reader.py b/ydb/_topic_reader/topic_reader.py index b3d5637d..326729a6 100644 --- a/ydb/_topic_reader/topic_reader.py +++ b/ydb/_topic_reader/topic_reader.py @@ -38,6 +38,10 @@ class PublicReaderSettings: decoder_executor: Optional[concurrent.futures.Executor] = None update_token_interval: Union[int, float] = 3600 + def __post_init__(self): + # check possible create init message + _ = self._init_message() + def _init_message(self) -> StreamReadMessage.InitRequest: return StreamReadMessage.InitRequest( topics_read_settings=[ diff --git a/ydb/topic.py b/ydb/topic.py index 090935b3..63f235be 100644 --- a/ydb/topic.py +++ b/ydb/topic.py @@ -13,8 +13,10 @@ "TopicReaderAsyncIO", "TopicReaderSettings", "TopicStatWindow", + "TopicWriteResult", "TopicWriter", "TopicWriterAsyncIO", + "TopicWriterInitInfo", "TopicWriterMessage", "TopicWriterSettings", ] @@ -42,6 +44,8 @@ PublicWriterSettings as TopicWriterSettings, PublicMessage as TopicWriterMessage, RetryPolicy as TopicWriterRetryPolicy, + PublicWriterInitInfo as TopicWriterInitInfo, + PublicWriteResult as TopicWriteResult, ) from ydb._topic_writer.topic_writer_asyncio import WriterAsyncIO as TopicWriterAsyncIO