aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorrobot-kikimr-dev <robot-kikimr-dev@yandex-team.ru>2022-02-21 00:31:05 +0300
committerrobot-kikimr-dev <robot-kikimr-dev@yandex-team.ru>2022-02-21 00:31:05 +0300
commit7be9f9cee9ebe6b5f0c2c9084810df68bd5731b2 (patch)
tree8243041c70227136207d6a5f0bf5b97240285c93
parentbab22eebdf894b271f661f2474068552165277b4 (diff)
downloadydb-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.txt2
-rw-r--r--ydb/public/sdk/python/tests/aio/test_async_iter_stream.py4
-rw-r--r--ydb/public/sdk/python/ydb/connection.py4
-rw-r--r--ydb/public/sdk/python/ydb/convert.py12
-rw-r--r--ydb/public/sdk/python/ydb/driver.py10
-rw-r--r--ydb/public/sdk/python/ydb/ydb_version.py2
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"