Add proper version to client (#67)

Author: cretz

temporalio/__init__.py

@@ -1 +1,5 @@
 """Python SDK for Temporal."""
+
+from .workflow_service import __version__ as __sdk_version
+
+__version__ = __sdk_version

temporalio/bridge/client.py

@@ -43,9 +43,8 @@ class ClientConfig:
     worker_binary_id: str
     tls_config: Optional[ClientTlsConfig]
     retry_config: Optional[ClientRetryConfig]
-    client_name: str = "temporal-python"
-    # TODO(cretz): Take from importlib ref https://stackoverflow.com/a/54869712
-    client_version: str = "0.1.0"
+    client_name: str
+    client_version: str
 
 
 ProtoMessage = TypeVar("ProtoMessage", bound=google.protobuf.message.Message)

temporalio/workflow_service.py

@@ -20,6 +20,8 @@
 import temporalio.bridge.telemetry
 import temporalio.exceptions
 
+__version__ = "0.1a2"
+
 WorkflowServiceRequest = TypeVar(
     "WorkflowServiceRequest", bound=google.protobuf.message.Message
 )
@@ -118,6 +120,8 @@ def _to_bridge_config(self) -> temporalio.bridge.client.ClientConfig:
             static_headers=self.static_headers,
             identity=self.identity,
             worker_binary_id=self.worker_binary_id or "",
+            client_name="temporal-python",
+            client_version=__version__,
         )
 
 

tests/test_workflow_service.py

@@ -1,9 +1,11 @@
 import inspect
+import os
 import re
 from typing import Dict, Tuple, Type
 
 import grpc
 
+import temporalio
 import temporalio.api.workflowservice.v1
 import temporalio.workflow_service
 from temporalio.client import Client
@@ -49,3 +51,15 @@ def unary_unary(self, method, request_serializer, response_deserializer):
 
 
 CallCollectingChannel.__abstractmethods__ = set()
+
+
+def test_version():
+    # Extract version from pyproject.toml
+    with open(
+        os.path.join(os.path.dirname(__file__), "..", "pyproject.toml"), "r"
+    ) as f:
+        pyproject = f.read()
+    version = pyproject[pyproject.find('version = "') + 11 :]
+    version = version[: version.find('"')]
+    assert temporalio.workflow_service.__version__ == version
+    assert temporalio.__version__ == version