diff options
author | robot-kikimr-dev <robot-kikimr-dev@yandex-team.ru> | 2022-02-21 00:31:05 +0300 |
---|---|---|
committer | robot-kikimr-dev <robot-kikimr-dev@yandex-team.ru> | 2022-02-21 00:31:05 +0300 |
commit | 7be9f9cee9ebe6b5f0c2c9084810df68bd5731b2 (patch) | |
tree | 8243041c70227136207d6a5f0bf5b97240285c93 | |
parent | bab22eebdf894b271f661f2474068552165277b4 (diff) | |
download | ydb-7be9f9cee9ebe6b5f0c2c9084810df68bd5731b2.tar.gz |
Sync YDB SDK from github
Release YDB recipe binaries
ref:e7e24b9e5e504ede22af37b8af59adb54fb5e726
-rw-r--r-- | ydb/public/sdk/python/examples/reservations-bot-demo/cloud_function/requirements.txt | 2 | ||||
-rw-r--r-- | ydb/public/sdk/python/tests/aio/test_async_iter_stream.py | 4 | ||||
-rw-r--r-- | ydb/public/sdk/python/ydb/connection.py | 4 | ||||
-rw-r--r-- | ydb/public/sdk/python/ydb/convert.py | 12 | ||||
-rw-r--r-- | ydb/public/sdk/python/ydb/driver.py | 10 | ||||
-rw-r--r-- | ydb/public/sdk/python/ydb/ydb_version.py | 2 |
6 files changed, 15 insertions, 19 deletions
diff --git a/ydb/public/sdk/python/examples/reservations-bot-demo/cloud_function/requirements.txt b/ydb/public/sdk/python/examples/reservations-bot-demo/cloud_function/requirements.txt index 8a4d06a346e..68f0907b5da 100644 --- a/ydb/public/sdk/python/examples/reservations-bot-demo/cloud_function/requirements.txt +++ b/ydb/public/sdk/python/examples/reservations-bot-demo/cloud_function/requirements.txt @@ -6,7 +6,7 @@ enum-compat==0.0.3 googleapis-common-protos==1.52.0 grpcio==1.31.0 idna==2.10 -protobuf==3.13.0 +protobuf==3.15.0 pycparser==2.20 pydantic==1.6.2 PyJWT==1.7.1 diff --git a/ydb/public/sdk/python/tests/aio/test_async_iter_stream.py b/ydb/public/sdk/python/tests/aio/test_async_iter_stream.py index 799cb7aabb2..c88104991f3 100644 --- a/ydb/public/sdk/python/tests/aio/test_async_iter_stream.py +++ b/ydb/public/sdk/python/tests/aio/test_async_iter_stream.py @@ -63,7 +63,7 @@ async def test_read_shard_table(driver, database): data_by_shard_id = {} with session.transaction() as tx: - max_value = 2 ** 64 + max_value = 2**64 shard_key_bound = max_value >> 3 data = [] @@ -75,7 +75,7 @@ async def test_read_shard_table(driver, database): table_row = { "Key1": shard_id * shard_key_bound + idx, "Key2": idx + 1000, - "Value": str(idx ** 4), + "Value": str(idx**4), } data_by_shard_id[shard_id].append(table_row) data.append(table_row) diff --git a/ydb/public/sdk/python/ydb/connection.py b/ydb/public/sdk/python/ydb/connection.py index 573b276e207..e3af3d5dca8 100644 --- a/ydb/public/sdk/python/ydb/connection.py +++ b/ydb/public/sdk/python/ydb/connection.py @@ -176,7 +176,7 @@ def _construct_channel_options(driver_config, endpoint_options=None): :param endpoint_options: Endpoint options :return: A channel initialization options """ - _max_message_size = 64 * 10 ** 6 + _max_message_size = 64 * 10**6 _default_connect_options = [ ("grpc.max_receive_message_length", _max_message_size), ("grpc.max_send_message_length", _max_message_size), @@ -269,7 +269,7 @@ class _RpcState(object): return self.rendezvous, self.result_future -_nanos_in_second = 10 ** 9 +_nanos_in_second = 10**9 def _set_duration(duration_value, seconds_float): diff --git a/ydb/public/sdk/python/ydb/convert.py b/ydb/public/sdk/python/ydb/convert.py index 0b0176e04ed..2be209bf1c6 100644 --- a/ydb/public/sdk/python/ydb/convert.py +++ b/ydb/public/sdk/python/ydb/convert.py @@ -7,11 +7,11 @@ from . import issues, types, _apis _SHIFT_BIT_COUNT = 64 -_SHIFT = 2 ** 64 -_SIGN_BIT = 2 ** 63 -_DecimalNanRepr = 10 ** 35 + 1 -_DecimalInfRepr = 10 ** 35 -_DecimalSignedInfRepr = -(10 ** 35) +_SHIFT = 2**64 +_SIGN_BIT = 2**63 +_DecimalNanRepr = 10**35 + 1 +_DecimalInfRepr = 10**35 +_DecimalSignedInfRepr = -(10**35) _primitive_type_by_id = {} @@ -49,7 +49,7 @@ def _pb_to_decimal(type_pb, value_pb, table_client_settings): elif int128_value == _DecimalSignedInfRepr: return decimal.Decimal("-Inf") return decimal.Decimal(int128_value) / decimal.Decimal( - 10 ** type_pb.decimal_type.scale + 10**type_pb.decimal_type.scale ) diff --git a/ydb/public/sdk/python/ydb/driver.py b/ydb/public/sdk/python/ydb/driver.py index e14f90176e6..f04fb3ada76 100644 --- a/ydb/public/sdk/python/ydb/driver.py +++ b/ydb/public/sdk/python/ydb/driver.py @@ -1,7 +1,6 @@ # -*- coding: utf-8 -*- -import ydb - from . import credentials as credentials_impl, table, scheme, pool +from . import tracing import six import os @@ -41,7 +40,7 @@ def parse_connection_string(connection_string): def default_credentials(credentials=None, tracer=None): - tracer = tracer if tracer is not None else ydb.Tracer(None) + tracer = tracer if tracer is not None else tracing.Tracer(None) with tracer.trace("Driver.default_credentials") as ctx: if credentials is not None: ctx.trace({"credentials.prepared": True}) @@ -117,7 +116,6 @@ class DriverConfig(object): grpc_lb_policy_name="round_robin", discovery_request_timeout=10, ): - # type:(str, str, str, str, Any, ydb.Credentials, bool, bytes, bytes, bytes, float, ydb.TableClientSettings, list, str, ydb.Tracer) -> None """ A driver config to initialize a driver instance @@ -158,7 +156,7 @@ class DriverConfig(object): self.grpc_keep_alive_timeout = grpc_keep_alive_timeout self.table_client_settings = table_client_settings self.primary_user_agent = primary_user_agent - self.tracer = tracer if tracer is not None else ydb.Tracer(None) + self.tracer = tracer if tracer is not None else tracing.Tracer(None) self.grpc_lb_policy_name = grpc_lb_policy_name self.discovery_request_timeout = discovery_request_timeout @@ -235,8 +233,6 @@ class Driver(pool.ConnectionPool): credentials=None, **kwargs ): - # type:(DriverConfig, str, str, str, bytes, ydb.AbstractCredentials, **Any) -> None - """ Constructs a driver instance to be used in table and scheme clients. It encapsulates endpoints discovery mechanism and provides ability to execute RPCs diff --git a/ydb/public/sdk/python/ydb/ydb_version.py b/ydb/public/sdk/python/ydb/ydb_version.py index 2101409026b..127c148a32d 100644 --- a/ydb/public/sdk/python/ydb/ydb_version.py +++ b/ydb/public/sdk/python/ydb/ydb_version.py @@ -1 +1 @@ -VERSION = "2.0.0" +VERSION = "2.1.0" |