diff options
| author | robot-kikimr-dev <robot-kikimr-dev@yandex-team.com> | 2023-08-18 18:47:13 +0300 |
|---|---|---|
| committer | robot-kikimr-dev <robot-kikimr-dev@yandex-team.com> | 2023-08-18 20:42:09 +0300 |
| commit | 4ec2d0800c4d84d6dc306fb71461bbfd396aea3a (patch) | |
| tree | 8d2238fa4154d15bc98d45badaa8034e4cd78c55 | |
| parent | 84a01ff9e85a339aae0f9918e09c007e272cb870 (diff) | |
| download | ydb-4ec2d0800c4d84d6dc306fb71461bbfd396aea3a.tar.gz | |
YDB SDK Sync from git
| -rw-r--r-- | ydb/public/sdk/python3/ydb/topic.py | 7 | ||||
| -rw-r--r-- | ydb/public/sdk/python3/ydb/ydb_version.py | 2 |
2 files changed, 6 insertions, 3 deletions
diff --git a/ydb/public/sdk/python3/ydb/topic.py b/ydb/public/sdk/python3/ydb/topic.py index d598fb7d2e..e0d3cf2dd1 100644 --- a/ydb/public/sdk/python3/ydb/topic.py +++ b/ydb/public/sdk/python3/ydb/topic.py @@ -11,6 +11,7 @@ __all__ = [ "TopicMeteringMode", "TopicReader", "TopicReaderAsyncIO", + "TopicReaderMessage", "TopicReaderSelector", "TopicReaderSettings", "TopicReaderPartitionExpiredError", @@ -32,6 +33,8 @@ from . import aio, Credentials, _apis, issues from . import driver +from ._topic_reader.datatypes import PublicMessage as TopicReaderMessage + from ._topic_reader.topic_reader import ( PublicReaderSettings as TopicReaderSettings, PublicTopicSelector as TopicReaderSelector, @@ -318,7 +321,7 @@ class TopicClient: if not decoder_executor: decoder_executor = self._executor - args = locals() + args = locals().copy() del args["self"] self._check_closed() @@ -339,7 +342,7 @@ class TopicClient: encoders: Optional[Mapping[_ydb_topic_public_types.PublicCodec, Callable[[bytes], bytes]]] = None, encoder_executor: Optional[concurrent.futures.Executor] = None, # default shared client executor pool ) -> TopicWriter: - args = locals() + args = locals().copy() del args["self"] self._check_closed() diff --git a/ydb/public/sdk/python3/ydb/ydb_version.py b/ydb/public/sdk/python3/ydb/ydb_version.py index 6e381816e2..78ab3284ca 100644 --- a/ydb/public/sdk/python3/ydb/ydb_version.py +++ b/ydb/public/sdk/python3/ydb/ydb_version.py @@ -1 +1 @@ -VERSION = "3.3.6" +VERSION = "3.3.7" |