use older-style union syntax for Python 3.9 compatability

Author: jazev-stripe

temporalio/bridge/client.py

@@ -7,7 +7,7 @@
 
 from dataclasses import dataclass
 from datetime import timedelta
-from typing import Mapping, Optional, Tuple, Type, TypeVar
+from typing import Mapping, Optional, Tuple, Type, TypeVar, Union
 
 import google.protobuf.message
 
@@ -59,7 +59,7 @@ class ClientConfig:
     """Python representation of the Rust struct for configuring the client."""
 
     target_url: str
-    metadata: Mapping[str, str | bytes]
+    metadata: Mapping[str, Union[str, bytes]]
     api_key: Optional[str]
     identity: str
     tls_config: Optional[ClientTlsConfig]
@@ -77,7 +77,7 @@ class RpcCall:
     rpc: str
     req: bytes
     retry: bool
-    metadata: Mapping[str, str | bytes]
+    metadata: Mapping[str, Union[str, bytes]]
     timeout_millis: Optional[int]
 
 
@@ -108,7 +108,7 @@ def __init__(
         self._runtime = runtime
         self._ref = ref
 
-    def update_metadata(self, metadata: Mapping[str, str | bytes]) -> None:
+    def update_metadata(self, metadata: Mapping[str, Union[str, bytes]]) -> None:
         """Update underlying metadata on Core client."""
         self._ref.update_metadata(metadata)
 
@@ -124,7 +124,7 @@ async def call(
         req: google.protobuf.message.Message,
         resp_type: Type[ProtoMessage],
         retry: bool,
-        metadata: Mapping[str, str | bytes],
+        metadata: Mapping[str, Union[str, bytes]],
         timeout: Optional[timedelta],
     ) -> ProtoMessage:
         """Make RPC call using SDK Core."""

temporalio/client.py

@@ -244,7 +244,7 @@ async def start_workflow(
         start_delay: Optional[timedelta] = None,
         start_signal: Optional[str] = None,
         start_signal_args: Sequence[Any] = [],
-        rpc_metadata: Mapping[str, str | bytes] = {},
+        rpc_metadata: Mapping[str, Union[str, bytes]] = {},
         rpc_timeout: Optional[timedelta] = None,
         request_eager_start: bool = False,
         priority: temporalio.common.Priority = temporalio.common.Priority.default,
@@ -279,7 +279,7 @@ async def start_workflow(
         start_delay: Optional[timedelta] = None,
         start_signal: Optional[str] = None,
         start_signal_args: Sequence[Any] = [],
-        rpc_metadata: Mapping[str, str | bytes] = {},
+        rpc_metadata: Mapping[str, Union[str, bytes]] = {},
         rpc_timeout: Optional[timedelta] = None,
         request_eager_start: bool = False,
         priority: temporalio.common.Priority = temporalio.common.Priority.default,
@@ -316,7 +316,7 @@ async def start_workflow(
         start_delay: Optional[timedelta] = None,
         start_signal: Optional[str] = None,
         start_signal_args: Sequence[Any] = [],
-        rpc_metadata: Mapping[str, str | bytes] = {},
+        rpc_metadata: Mapping[str, Union[str, bytes]] = {},
         rpc_timeout: Optional[timedelta] = None,
         request_eager_start: bool = False,
         priority: temporalio.common.Priority = temporalio.common.Priority.default,
@@ -353,7 +353,7 @@ async def start_workflow(
         start_delay: Optional[timedelta] = None,
         start_signal: Optional[str] = None,
         start_signal_args: Sequence[Any] = [],
-        rpc_metadata: Mapping[str, str | bytes] = {},
+        rpc_metadata: Mapping[str, Union[str, bytes]] = {},
         rpc_timeout: Optional[timedelta] = None,
         request_eager_start: bool = False,
         priority: temporalio.common.Priority = temporalio.common.Priority.default,
@@ -388,7 +388,7 @@ async def start_workflow(
         start_delay: Optional[timedelta] = None,
         start_signal: Optional[str] = None,
         start_signal_args: Sequence[Any] = [],
-        rpc_metadata: Mapping[str, str | bytes] = {},
+        rpc_metadata: Mapping[str, Union[str, bytes]] = {},
         rpc_timeout: Optional[timedelta] = None,
         request_eager_start: bool = False,
         priority: temporalio.common.Priority = temporalio.common.Priority.default,

temporalio/nexus/_operation_context.py

@@ -143,7 +143,7 @@ class ConnectConfig:
     tls: Union[bool, TLSConfig] = False
     retry_config: Optional[RetryConfig] = None
     keep_alive_config: Optional[KeepAliveConfig] = KeepAliveConfig.default
-    rpc_metadata: Mapping[str, str | bytes] = field(default_factory=dict)
+    rpc_metadata: Mapping[str, Union[str, bytes]] = field(default_factory=dict)
     identity: str = ""
     lazy: bool = False
     runtime: Optional[temporalio.runtime.Runtime] = None
@@ -232,7 +232,7 @@ async def check_health(
         *,
         service: str = "temporal.api.workflowservice.v1.WorkflowService",
         retry: bool = False,
-        metadata: Mapping[str, str | bytes] = {},
+        metadata: Mapping[str, Union[str, bytes]] = {},
         timeout: Optional[timedelta] = None,
     ) -> bool:
         """Check whether the WorkflowService is up.
@@ -264,7 +264,7 @@ def worker_service_client(self) -> _BridgeServiceClient:
         raise NotImplementedError
 
     @abstractmethod
-    def update_rpc_metadata(self, metadata: Mapping[str, str | bytes]) -> None:
+    def update_rpc_metadata(self, metadata: Mapping[str, Union[str, bytes]]) -> None:
         """Update service client's RPC metadata."""
         raise NotImplementedError
 
@@ -282,7 +282,7 @@ async def _rpc_call(
         *,
         service: str,
         retry: bool,
-        metadata: Mapping[str, str | bytes],
+        metadata: Mapping[str, Union[str, bytes]],
         timeout: Optional[timedelta],
     ) -> ServiceResponse:
         raise NotImplementedError
@@ -1257,7 +1257,7 @@ async def __call__(
         req: ServiceRequest,
         *,
         retry: bool = False,
-        metadata: Mapping[str, str | bytes] = {},
+        metadata: Mapping[str, Union[str, bytes]] = {},
         timeout: Optional[timedelta] = None,
     ) -> ServiceResponse:
         """Invoke underlying client with the given request.
@@ -1316,7 +1316,7 @@ def worker_service_client(self) -> _BridgeServiceClient:
         """Underlying service client."""
         return self
 
-    def update_rpc_metadata(self, metadata: Mapping[str, str | bytes]) -> None:
+    def update_rpc_metadata(self, metadata: Mapping[str, Union[str, bytes]]) -> None:
         """Update Core client metadata."""
         # Mutate the bridge config and then only mutate the running client
         # metadata if already connected
@@ -1340,7 +1340,7 @@ async def _rpc_call(
         *,
         service: str,
         retry: bool,
-        metadata: Mapping[str, str | bytes],
+        metadata: Mapping[str, Union[str, bytes]],
         timeout: Optional[timedelta],
     ) -> ServiceResponse:
         global LOG_PROTOS

temporalio/service.py

@@ -84,7 +84,7 @@ async def start_local(
             temporalio.common.QueryRejectCondition
         ] = None,
         retry_config: Optional[temporalio.client.RetryConfig] = None,
-        rpc_metadata: Mapping[str, str | bytes] = {},
+        rpc_metadata: Mapping[str, Union[str, bytes]] = {},
         identity: Optional[str] = None,
         tls: bool | temporalio.client.TLSConfig = False,
         ip: str = "127.0.0.1",
@@ -244,7 +244,7 @@ async def start_time_skipping(
             temporalio.common.QueryRejectCondition
         ] = None,
         retry_config: Optional[temporalio.client.RetryConfig] = None,
-        rpc_metadata: Mapping[str, str | bytes] = {},
+        rpc_metadata: Mapping[str, Union[str, bytes]] = {},
         identity: Optional[str] = None,
         port: Optional[int] = None,
         download_dest_dir: Optional[str] = None,
@@ -573,7 +573,7 @@ async def result(
         self,
         *,
         follow_runs: bool = True,
-        rpc_metadata: Mapping[str, str | bytes] = {},
+        rpc_metadata: Mapping[str, Union[str, bytes]] = {},
         rpc_timeout: Optional[timedelta] = None,
     ) -> Any:
         async with self.env.time_skipping_unlocked():

temporalio/testing/_workflow.py

@@ -1,5 +1,5 @@
 from datetime import timedelta
-from typing import Mapping, Any, cast
+from typing import Mapping, Any, cast, Union
 import pytest
 import re
 
@@ -38,9 +38,9 @@ def assert_time_remaining(context: ServicerContext, expected: int) -> None:
 class SimpleWorkflowServer(WorkflowServiceServicer):
     def __init__(self) -> None:
         super().__init__()
-        self.last_metadata: Mapping[str, str | bytes] = {}
+        self.last_metadata: Mapping[str, Union[str, bytes]] = {}
 
-    def assert_last_metadata(self, expected: Mapping[str, str | bytes]) -> None:
+    def assert_last_metadata(self, expected: Mapping[str, Union[str, bytes]]) -> None:
         for k, v in expected.items():
             assert self.last_metadata.get(k) == v
 

tests/api/test_grpc_stub.py

@@ -4,7 +4,7 @@
 import os
 import uuid
 from datetime import datetime, timedelta, timezone
-from typing import Any, List, Mapping, Optional, Tuple, cast
+from typing import Any, List, Mapping, Optional, Tuple, cast, Union
 from unittest import mock
 
 import google.protobuf.any_pb2
@@ -324,7 +324,7 @@ async def __call__(
             req: temporalio.api.workflowservice.v1.StartWorkflowExecutionRequest,
             *,
             retry: bool = False,
-            metadata: Mapping[str, str | bytes] = {},
+            metadata: Mapping[str, Union[str, bytes]] = {},
             timeout: Optional[timedelta] = None,
         ) -> temporalio.api.workflowservice.v1.StartWorkflowExecutionResponse:
             raise self.already_exists_err

tests/test_client.py

@@ -5,7 +5,7 @@
 from dataclasses import dataclass
 from datetime import timedelta
 from enum import Enum, IntEnum
-from typing import Any, Mapping, Optional
+from typing import Any, Mapping, Optional, Union
 from unittest.mock import patch
 
 import temporalio.api.common.v1
@@ -822,7 +822,7 @@ async def __call__(
             req: temporalio.api.workflowservice.v1.ExecuteMultiOperationRequest,
             *,
             retry: bool = False,
-            metadata: Mapping[str, str | bytes] = {},
+            metadata: Mapping[str, Union[str, bytes]] = {},
             timeout: Optional[timedelta] = None,
         ) -> temporalio.api.workflowservice.v1.ExecuteMultiOperationResponse:
             raise self.empty_details_err