fixed SDK incompatibility with old grpcio versions

Author: gridnevvvit

CHANGELOG.md

@@ -1,3 +1,7 @@
+## 2.8.0 ##
+
+* fixed the SDK incompatibility with old grpcio versions.
+
 ## 2.7.0 ##
 
 * fixes in TxContext in ydb.aio module.

setup.py

@@ -6,7 +6,7 @@
 
 setuptools.setup(
     name="ydb",
-    version="2.8.0",
+    version="2.9.0",
     description="YDB Python SDK",
     author="Yandex LLC",
     author_email="ydb@yandex-team.ru",

ydb/connection.py

@@ -304,23 +304,21 @@ def channel_factory(
     options = _construct_channel_options(driver_config, endpoint_options)
     logger.debug("Channel options: {}".format(options))
 
+    kwargs = {}
+    compression = getattr(driver_config, "compression", None)
+    if compression is not None:
+        kwargs = {"compression": compression}
+
     if driver_config.root_certificates is None and not driver_config.secure_channel:
-        return channel_provider.insecure_channel(
-            endpoint, options, compression=getattr(driver_config, "compression", None)
-        )
+        return channel_provider.insecure_channel(endpoint, options, **kwargs)
 
     root_certificates = driver_config.root_certificates
     if root_certificates is None:
         root_certificates = default_pem.load_default_pem()
     credentials = grpc.ssl_channel_credentials(
         root_certificates, driver_config.private_key, driver_config.certificate_chain
     )
-    return channel_provider.secure_channel(
-        endpoint,
-        credentials,
-        options,
-        compression=getattr(driver_config, "compression", None),
-    )
+    return channel_provider.secure_channel(endpoint, credentials, options, **kwargs)
 
 
 class EndpointKey(object):
@@ -434,11 +432,14 @@ def future(
         rpc_state, timeout, metadata = self._prepare_call(
             stub, rpc_name, request, settings
         )
+
+        kwargs = {}
+        compression = getattr(settings, "compression", None)
+        if compression is not None:
+            kwargs = {"compression": compression}
+
         rendezvous, result_future = rpc_state.future(
-            request,
-            timeout,
-            metadata,
-            compression=getattr(settings, "compression", None),
+            request, timeout, metadata, **kwargs
         )
         rendezvous.add_done_callback(
             lambda resp_future: _on_response_callback(
@@ -477,12 +478,12 @@ def __call__(
             stub, rpc_name, request, settings
         )
         try:
-            response = rpc_state(
-                request,
-                timeout,
-                metadata,
-                compression=getattr(settings, "compression", None),
-            )
+            kwargs = {}
+            compression = getattr(settings, "compression", None)
+            if compression is not None:
+                kwargs = {"compression": compression}
+
+            response = rpc_state(request, timeout, metadata, **kwargs)
             _log_response(rpc_state, response)
             return (
                 response

ydb/ydb_version.py

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