TD-P002: Python workers do not prove worker protocol 1.1 feature-floor handling (#28)

Author: durable-workflow-ops

CHANGELOG.md

@@ -18,7 +18,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 - Targeting continued alignment with the Durable Workflow v2 protocol
   surface advertised by `/api/cluster/info`
   (`control_plane.version: "2"`, request-contract version `1`,
-  `worker_protocol.version: "1.0"`). Remaining v2 follow-ups tracked for
+  `worker_protocol.version: "1.1"`). Remaining v2 follow-ups tracked for
   this line: server-routed Python query execution and pre-accept update
   validator routing.
 

README.md

@@ -457,13 +457,13 @@ Full documentation is available at
 
 ## Compatibility
 
-SDK version 0.2.x is compatible with servers that advertise these protocol
+SDK version 0.4.x is compatible with servers that advertise these protocol
 manifests from `GET /api/cluster/info`:
 
 - `control_plane.version: "2"`
 - `control_plane.request_contract.schema: durable-workflow.v2.control-plane-request.contract` version `1`
 - `auth_composition_contract.schema: durable-workflow.v2.auth-composition.contract` version `1`
-- `worker_protocol.version: "1.0"`
+- `worker_protocol.version: "1.1"`
 - `worker_protocol.external_task_input_contract.schema: durable-workflow.v2.external-task-input.contract` version `1`
 - `worker_protocol.external_task_result_contract.schema: durable-workflow.v2.external-task-result.contract` version `1`
 

src/durable_workflow/client.py

@@ -42,7 +42,7 @@
 from .metrics import CLIENT_REQUEST_DURATION_SECONDS, CLIENT_REQUESTS, NOOP_METRICS, MetricsRecorder
 from .retry_policy import TransportRetryPolicy
 
-PROTOCOL_VERSION = "1.0"
+PROTOCOL_VERSION = "1.1"
 CONTROL_PLANE_VERSION = "2"
 CONTROL_PLANE_REQUEST_CONTRACT_SCHEMA = "durable-workflow.v2.control-plane-request.contract"
 CONTROL_PLANE_REQUEST_CONTRACT_VERSION = 1

src/durable_workflow/worker.py

@@ -169,14 +169,14 @@ def _validate_server_compatibility(info: dict[str, Any]) -> None:
     if not isinstance(control_plane, dict):
         raise RuntimeError(
             "Server compatibility error: missing control_plane manifest; "
-            f"sdk-python 0.2.x requires control_plane.version {CONTROL_PLANE_VERSION}."
+            f"sdk-python requires control_plane.version {CONTROL_PLANE_VERSION}."
         )
 
     control_plane_version = _manifest_version(control_plane)
     if control_plane_version != CONTROL_PLANE_VERSION:
         raise RuntimeError(
             "Server compatibility error: unsupported control_plane.version "
-            f"{control_plane_version!r}; sdk-python 0.2.x requires {CONTROL_PLANE_VERSION!r}."
+            f"{control_plane_version!r}; sdk-python requires {CONTROL_PLANE_VERSION!r}."
         )
 
     request_contract = control_plane.get("request_contract")
@@ -202,14 +202,14 @@ def _validate_server_compatibility(info: dict[str, Any]) -> None:
     if not isinstance(worker_protocol, dict):
         raise RuntimeError(
             "Server compatibility error: missing worker_protocol manifest; "
-            f"sdk-python 0.2.x requires worker_protocol.version {PROTOCOL_VERSION}."
+            f"sdk-python requires worker_protocol.version {PROTOCOL_VERSION}."
         )
 
     worker_protocol_version = _manifest_version(worker_protocol)
     if worker_protocol_version != PROTOCOL_VERSION:
         raise RuntimeError(
             "Server compatibility error: unsupported worker_protocol.version "
-            f"{worker_protocol_version!r}; sdk-python 0.2.x requires {PROTOCOL_VERSION!r}."
+            f"{worker_protocol_version!r}; sdk-python requires {PROTOCOL_VERSION!r}."
         )
 
     auth_composition = info.get("auth_composition_contract")

tests/test_worker.py

@@ -341,6 +341,45 @@ async def test_register_rejects_unsupported_worker_protocol_version(self, mock_c
             await worker._register()
         mock_client.register_worker.assert_not_called()
 
+    @pytest.mark.asyncio
+    async def test_register_rejects_worker_protocol_below_payload_codec_floor(
+        self, mock_client: AsyncMock
+    ) -> None:
+        mock_client.get_cluster_info = AsyncMock(
+            return_value=compatible_cluster_info(worker_protocol={"version": "1.0"})
+        )
+        worker = Worker(mock_client, task_queue="q1", workflows=[TestWorkflow], activities=[])
+        with pytest.raises(RuntimeError, match="requires '1.1'"):
+            await worker._register()
+        mock_client.register_worker.assert_not_called()
+
+    @pytest.mark.asyncio
+    async def test_register_accepts_protocol_1_1_when_newer_feature_floor_is_unavailable(
+        self, mock_client: AsyncMock
+    ) -> None:
+        mock_client.get_cluster_info = AsyncMock(
+            return_value=compatible_cluster_info(
+                worker_protocol={
+                    "version": PROTOCOL_VERSION,
+                    "server_capabilities": {
+                        "query_tasks": True,
+                        "worker_session_verbs": [],
+                        "worker_sessions": {
+                            "feature": "worker_sessions",
+                            "supported": False,
+                            "minimum_protocol_version": "1.2",
+                            "unavailable_reason": "worker_protocol_version_below_worker_session_minimum",
+                        },
+                    },
+                }
+            )
+        )
+        worker = Worker(mock_client, task_queue="q1", workflows=[TestWorkflow], activities=[])
+
+        await worker._register()
+
+        mock_client.register_worker.assert_awaited_once()
+
     @pytest.mark.asyncio
     async def test_register_rejects_missing_auth_composition_contract(self, mock_client: AsyncMock) -> None:
         mock_client.get_cluster_info = AsyncMock(return_value=compatible_cluster_info(auth_composition_contract=None))