We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 3dba5c7 commit 92a2988Copy full SHA for 92a2988
ydb/_topic_reader/topic_reader.py
@@ -39,8 +39,8 @@ class PublicReaderSettings:
39
update_token_interval: Union[int, float] = 3600
40
41
def __post_init__(self):
42
- if not isinstance(self.consumer, str):
43
- raise TypeError("Unsupported type for consumer: '%s'" % type(self.consumer))
+ # check possible create init message
+ _ = self._init_message()
44
45
def _init_message(self) -> StreamReadMessage.InitRequest:
46
return StreamReadMessage.InitRequest(
0 commit comments