Merge pull request #41 from ydb-platform/fix-issues-in-aio-library

fixes in sdk

Author: gridnevvvit

setup.py

@@ -6,7 +6,7 @@
 
 setuptools.setup(
     name="ydb",
-    version="2.7.0",
+    version="2.8.0",
     description="YDB Python SDK",
     author="Yandex LLC",
     author_email="[email protected]",

ydb/iam/auth.py

@@ -53,6 +53,8 @@ def __init__(self, iam_endpoint=None, iam_channel_credentials=None, tracer=None)
             iam_token_service_pb2_grpc is not None
         ), "run pip install==ydb[yc] to use service account credentials"
         self._get_token_request_timeout = 10
+        self._iam_token_service_pb2 = iam_token_service_pb2
+        self._iam_token_service_pb2_grpc = iam_token_service_pb2_grpc
         self._iam_endpoint = (
             "iam.api.cloud.yandex.net:443" if iam_endpoint is None else iam_endpoint
         )
@@ -74,7 +76,7 @@ def _get_token_request(self):
     def _make_token_request(self):
         with self._channel_factory() as channel:
             tracing.trace(self.tracer, {"iam_token.from_service": True})
-            stub = iam_token_service_pb2_grpc.IamTokenServiceStub(channel)
+            stub = self._iam_token_service_pb2_grpc.IamTokenServiceStub(channel)
             response = stub.Create(
                 self._get_token_request(), timeout=self._get_token_request_timeout
             )
@@ -124,7 +126,7 @@ def __init__(
         BaseJWTCredentials.__init__(self, account_id, access_key_id, private_key)
 
     def _get_token_request(self):
-        return iam_token_service_pb2.CreateIamTokenRequest(
+        return self._iam_token_service_pb2.CreateIamTokenRequest(
             jwt=get_jwt(
                 self._account_id,
                 self._access_key_id,

ydb/scheme.py

@@ -22,6 +22,7 @@ class SchemeEntryType(enum.IntEnum):
     COLUMN_TABLE = 13
     SEQUENCE = 15
     REPLICATION = 16
+    TOPIC = 17
 
     @staticmethod
     def is_table(entry):

ydb/table.py

@@ -998,6 +998,7 @@ def __init__(self):
         self._make_result_sets_lazy = False
         self._native_json_in_result_sets = False
         self._native_interval_in_result_sets = False
+        self._native_timestamp_in_result_sets = False
 
     def with_native_timestamp_in_result_sets(self, enabled):
         # type:(bool) -> ydb.TableClientSettings

ydb/ydb_version.py

@@ -1 +1 @@
-VERSION = "2.7.0"
+VERSION = "2.8.0"