fix: Use pre-3.9 dict merge operator

CHANGELOG.md

@@ -1,3 +1,9 @@
+## Unreleased
+
+### Bug fixes
+
+- Use pre-3.9 dict merge operator
+
 ## v0.10.4 (2024-01-24)
 
 ### Bug fixes

README.md

@@ -132,6 +132,8 @@ You can pass additional options in the `channel_options` dict.
 Available options are described [here](https://github.com/grpc/grpc/blob/7536d8a849c0096e4c968e7730306872bb5ec674/include/grpc/impl/grpc_types.h).
 The argument is of type `dict[str, Any]` where the `Any` value must match the expected type defined in the previous link.
 
+IMPORTANT: We use the config key `grpc.service_config` to set service-specific configuration (retry policies, backoffs etc) within the nested JSON field. Passing this as a `channel_options` key will override that configuration entirely. We recommend leaving this untouched, however, if you need to pass custom config, ensure you pass the entire existing dict along with the desired updates (this can be found within the `AsyncClientBase.__init__` method).
+
 NOTE: We provide this as a generic method to set arbitrary options for particular use cases.
 For purely demonstrative purposes, our example below overrides `grpc.ssl_target_name_override`, which is certainly not recommended practice for production applications.
 

cerbos/sdk/_async/_grpc.py

@@ -6,7 +6,7 @@
 import ssl
 import uuid
 from functools import wraps
-from typing import Any, Dict, List, Tuple, Union
+from typing import Any, Dict, List, Optional, Tuple, Union
 
 import grpc
 
@@ -79,8 +79,8 @@ class AsyncClientBase:
     def __init__(
         self,
         host: str,
-        creds: grpc.ChannelCredentials,
-        methods: List[Dict[str, str]] = None,
+        creds: Optional[grpc.ChannelCredentials],
+        methods: Optional[List[Dict[str, str]]] = None,
         tls_verify: TLSVerify = False,
         timeout_secs: Union[float, None] = None,
         request_retries: int = 0,
@@ -123,10 +123,10 @@ def __init__(
         }
 
         if channel_options:
-            options |= channel_options
+            options = {**options, **channel_options}
 
         opts = [(k, v) for k, v in options.items()]
-        if tls_verify:
+        if tls_verify and creds:
             self._channel = grpc.aio.secure_channel(
                 host,
                 credentials=creds,
@@ -179,7 +179,7 @@ def __init__(
         wait_for_ready: bool = False,
         channel_options: Union[Dict[str, Any], None] = None,
     ):
-        creds: grpc.ChannelCredentials = None
+        creds: Optional[grpc.ChannelCredentials] = None
         if tls_verify:
             cert = get_cert(tls_verify)
             creds = grpc.ssl_channel_credentials(cert)
@@ -448,7 +448,7 @@ def __init__(
         admin_credentials = admin_credentials or AdminCredentials()
         self._creds_metadata = admin_credentials.metadata()
 
-        creds: grpc.ChannelCredentials = None
+        creds: Optional[grpc.ChannelCredentials] = None
         if tls_verify:
             cert = get_cert(tls_verify)
             creds = grpc.ssl_channel_credentials(cert)

cerbos/sdk/_sync/_grpc.py

@@ -6,7 +6,7 @@
 import ssl
 import uuid
 from functools import wraps
-from typing import Any, Dict, List, Tuple, Union
+from typing import Any, Dict, List, Optional, Tuple, Union
 
 import grpc
 
@@ -79,8 +79,8 @@ class SyncClientBase:
     def __init__(
         self,
         host: str,
-        creds: grpc.ChannelCredentials,
-        methods: List[Dict[str, str]] = None,
+        creds: Optional[grpc.ChannelCredentials],
+        methods: Optional[List[Dict[str, str]]] = None,
         tls_verify: TLSVerify = False,
         timeout_secs: Union[float, None] = None,
         request_retries: int = 0,
@@ -123,10 +123,10 @@ def __init__(
         }
 
         if channel_options:
-            options |= channel_options
+            options = {**options, **channel_options}
 
         opts = [(k, v) for k, v in options.items()]
-        if tls_verify:
+        if tls_verify and creds:
             self._channel = grpc.secure_channel(
                 host,
                 credentials=creds,
@@ -179,7 +179,7 @@ def __init__(
         wait_for_ready: bool = False,
         channel_options: Union[Dict[str, Any], None] = None,
     ):
-        creds: grpc.ChannelCredentials = None
+        creds: Optional[grpc.ChannelCredentials] = None
         if tls_verify:
             cert = get_cert(tls_verify)
             creds = grpc.ssl_channel_credentials(cert)
@@ -448,7 +448,7 @@ def __init__(
         admin_credentials = admin_credentials or AdminCredentials()
         self._creds_metadata = admin_credentials.metadata()
 
-        creds: grpc.ChannelCredentials = None
+        creds: Optional[grpc.ChannelCredentials] = None
         if tls_verify:
             cert = get_cert(tls_verify)
             creds = grpc.ssl_channel_credentials(cert)

pyproject.toml

@@ -2,10 +2,8 @@
 name = "cerbos"
 description = "SDK for working with Cerbos: an open core, language-agnostic, scalable authorization solution"
 readme = "README.md"
-authors = [
-    {name = "Cerbos Developers", email = "[email protected]"},
-]
-license = {text = "Apache-2.0"}
+authors = [{ name = "Cerbos Developers", email = "[email protected]" }]
+license = { text = "Apache-2.0" }
 classifiers = [
     "Development Status :: 4 - Beta",
     "Intended Audience :: Developers",
@@ -27,25 +25,18 @@ requires-python = ">=3.8"
 dynamic = ["version"]
 
 
-
 [project.urls]
 Homepage = "https://cerbos.dev"
 
 [project.optional-dependencies]
-testcontainers = [
-    "testcontainers>=3.5.3",
-]
+testcontainers = ["testcontainers>=3.5.3"]
 
 [tool.pdm.version]
 source = "scm"
 
 [tool.pdm.dev-dependencies]
-lint = [
-    "black>=22.3.0",
-    "isort>=5.10.1"]
-test = [
-    "pytest>=7.3.1",
-]
+lint = ["black>=22.3.0", "isort>=5.10.1"]
+test = ["pytest>=7.3.1"]
 tools = [
     "unasync>=0.5.0",
     "setuptools>=63.2.0",
@@ -59,13 +50,13 @@ tools = [
 includes = ["cerbos/", "google/", "buf/"]
 
 [tool.pdm.scripts]
-isort = {cmd = "isort cerbos/sdk tests"}
-black = {cmd = "black cerbos/sdk tests"}
-format = {composite = ["isort", "black"]}
-unasync = {cmd = "python utils/gen_unasync.py"}
-test = {cmd = "pytest"}
-pre_build = {composite = ["unasync", "format"]}
-pre_test = {composite = ["unasync", "format"]}
+isort = { cmd = "isort cerbos/sdk tests" }
+black = { cmd = "black cerbos/sdk tests" }
+format = { composite = ["isort", "black"] }
+unasync = { cmd = "python utils/gen_unasync.py" }
+test = { cmd = "pytest" }
+pre_build = { composite = ["unasync", "format"] }
+pre_test = { composite = ["unasync", "format"] }
 
 [build-system]
 requires = ["pdm-backend"]
@@ -91,6 +82,8 @@ tag_release = "pdm run cz bump --changelog --increment"
 changelog = "pdm run cz changelog"
 
 [tool.pyright]
+venvPath = "."
+venv = ".venv"
 extraPaths = ["__pypackages__/3.10/lib/"]
 
 [tool.pytest.ini_options]
@@ -109,5 +102,5 @@ update_changelog_on_bump = true
 
 [tool.commitizen.customize]
 commit_parser = "^(?P<change_type>feat|fix|enhancement|docs|chore)(\\\\(.*?\\\\))?:\\s(?P<message>.*)?"
-change_type_map = {"feat" = "Features", "fix" = "Bug fixes", "enhancement" = "Enhancements", "docs" = "Documentation", "chore" = "Chores"}
+change_type_map = { "feat" = "Features", "fix" = "Bug fixes", "enhancement" = "Enhancements", "docs" = "Documentation", "chore" = "Chores" }
 change_type_order = ["feat", "enhancement", "fix", "docs"]