small fixes

Author: rekby

ydb/aio/credentials.py

@@ -54,9 +54,7 @@ def submit(self, callback):
             asyncio.ensure_future(self._wrapped_execution(callback))
 
 
-class AbstractExpiringTokenCredentials(
-    credentials.AbstractExpiringTokenCredentials, abc.ABC
-):
+class AbstractExpiringTokenCredentials(credentials.AbstractExpiringTokenCredentials):
     def __init__(self):
         super(AbstractExpiringTokenCredentials, self).__init__()
         self._tp = _AtMostOneExecution()

ydb/aio/iam.py

@@ -23,7 +23,7 @@
     aiohttp = None
 
 
-class TokenServiceCredentials(AbstractExpiringTokenCredentials, abc.ABC):
+class TokenServiceCredentials(AbstractExpiringTokenCredentials):
     def __init__(self, iam_endpoint=None, iam_channel_credentials=None):
         super(TokenServiceCredentials, self).__init__()
         assert (

ydb/credentials.py

@@ -85,7 +85,7 @@ def cleanup(self):
             self._can_schedule = True
 
 
-class AbstractExpiringTokenCredentials(Credentials, abc.ABC):
+class AbstractExpiringTokenCredentials(Credentials):
     def __init__(self, tracer=None):
         super(AbstractExpiringTokenCredentials, self).__init__(tracer)
         self._expires_in = 0

ydb/iam/auth.py

@@ -44,7 +44,7 @@ def get_jwt(account_id, access_key_id, private_key, jwt_expiration_timeout):
     )
 
 
-class TokenServiceCredentials(credentials.AbstractExpiringTokenCredentials, abc.ABC):
+class TokenServiceCredentials(credentials.AbstractExpiringTokenCredentials):
     def __init__(self, iam_endpoint=None, iam_channel_credentials=None, tracer=None):
         super(TokenServiceCredentials, self).__init__(tracer)
         assert (

ydb/types.py

@@ -12,8 +12,6 @@
 _SECONDS_IN_DAY = 60 * 60 * 24
 _EPOCH = datetime(1970, 1, 1)
 
-_from_bytes = None
-
 
 def _from_date_number(x, table_client_settings):
     if (
@@ -39,8 +37,6 @@ def _from_json(x, table_client_settings):
         and table_client_settings._native_json_in_result_sets
     ):
         return json.loads(x)
-    if _from_bytes is not None:
-        return _from_bytes(x, table_client_settings)
     return x
 
 
@@ -109,7 +105,7 @@ class PrimitiveType(enum.Enum):
     Float = _apis.primitive_types.FLOAT, "float_value"
 
     String = _apis.primitive_types.STRING, "bytes_value"
-    Utf8 = _apis.primitive_types.UTF8, "text_value", _from_bytes
+    Utf8 = _apis.primitive_types.UTF8, "text_value"
 
     Yson = _apis.primitive_types.YSON, "bytes_value"
     Json = _apis.primitive_types.JSON, "text_value", _from_json
@@ -138,7 +134,7 @@ class PrimitiveType(enum.Enum):
         _to_interval,
     )
 
-    DyNumber = _apis.primitive_types.DYNUMBER, "text_value", _from_bytes
+    DyNumber = _apis.primitive_types.DYNUMBER, "text_value"
 
     def __init__(self, idn, proto_field, to_obj=None, from_obj=None):
         self._idn_ = idn