File tree Expand file tree Collapse file tree 2 files changed +8
-0
lines changed Expand file tree Collapse file tree 2 files changed +8
-0
lines changed Original file line number Diff line number Diff line change @@ -38,6 +38,10 @@ class PublicReaderSettings:
3838 decoder_executor : Optional [concurrent .futures .Executor ] = None
3939 update_token_interval : Union [int , float ] = 3600
4040
41+ def __post_init__ (self ):
42+ # check possible create init message
43+ _ = self ._init_message ()
44+
4145 def _init_message (self ) -> StreamReadMessage .InitRequest :
4246 return StreamReadMessage .InitRequest (
4347 topics_read_settings = [
Original file line number Diff line number Diff line change 1313 "TopicReaderAsyncIO" ,
1414 "TopicReaderSettings" ,
1515 "TopicStatWindow" ,
16+ "TopicWriteResult" ,
1617 "TopicWriter" ,
1718 "TopicWriterAsyncIO" ,
19+ "TopicWriterInitInfo" ,
1820 "TopicWriterMessage" ,
1921 "TopicWriterSettings" ,
2022]
4244 PublicWriterSettings as TopicWriterSettings ,
4345 PublicMessage as TopicWriterMessage ,
4446 RetryPolicy as TopicWriterRetryPolicy ,
47+ PublicWriterInitInfo as TopicWriterInitInfo ,
48+ PublicWriteResult as TopicWriteResult ,
4549)
4650
4751from ydb ._topic_writer .topic_writer_asyncio import WriterAsyncIO as TopicWriterAsyncIO
You can’t perform that action at this time.
0 commit comments