Assert workflow describe polyglot parity

Author: durable-workflow-ops

tests/fixtures/control-plane/workflow-describe-parity.json

@@ -0,0 +1,52 @@
+{
+  "schema": "durable-workflow.polyglot.control-plane-request-fixture",
+  "version": 1,
+  "operation": "workflow.describe",
+  "request": {
+    "method": "GET",
+    "path": "/workflows/wf-polyglot-231"
+  },
+  "semantic_body": {
+    "workflow_id": "wf-polyglot-231"
+  },
+  "response_body": {
+    "workflow_id": "wf-polyglot-231",
+    "run_id": "run-polyglot-231",
+    "workflow_type": "orders.process",
+    "namespace": "orders-prod",
+    "task_queue": "orders",
+    "status": "running",
+    "status_bucket": "active",
+    "business_key": "order-42",
+    "payload_codec": "avro",
+    "memo": {
+      "source": "polyglot-fixture"
+    },
+    "search_attributes": {
+      "CustomerId": "cust-42",
+      "Tier": "gold"
+    },
+    "input": [
+      {
+        "order_id": 42,
+        "priority": "gold"
+      }
+    ],
+    "actions": {
+      "can_query": true,
+      "can_signal": true,
+      "can_cancel": true
+    }
+  },
+  "cli": {
+    "argv": {
+      "workflow-id": "wf-polyglot-231",
+      "--json": true
+    }
+  },
+  "sdk_python": {
+    "args": {
+      "workflow_id": "wf-polyglot-231"
+    }
+  }
+}

tests/test_client.py

@@ -236,6 +236,34 @@ async def test_success(self, client: Client) -> None:
             assert isinstance(desc, WorkflowExecution)
             assert desc.status == "running"
 
+    @pytest.mark.asyncio
+    async def test_describe_request_matches_polyglot_fixture(self, client: Client) -> None:
+        fixture_path = Path(__file__).parent / "fixtures" / "control-plane" / "workflow-describe-parity.json"
+        fixture = json.loads(fixture_path.read_text())
+        sdk = fixture["sdk_python"]
+
+        resp = _mock_response(200, fixture["response_body"])
+
+        with patch.object(client._http, "request", new_callable=AsyncMock, return_value=resp) as mock:
+            desc = await client.describe_workflow(**sdk["args"])
+
+        call_args = mock.call_args
+        assert call_args.args[0] == fixture["request"]["method"]
+        assert call_args.args[1] == f"/api{fixture['request']['path']}"
+        assert call_args.kwargs.get("json") is None
+
+        semantic = fixture["semantic_body"]
+        response = fixture["response_body"]
+        assert sdk["args"]["workflow_id"] == semantic["workflow_id"]
+        assert desc.workflow_id == semantic["workflow_id"]
+        assert desc.run_id == response["run_id"]
+        assert desc.workflow_type == response["workflow_type"]
+        assert desc.namespace == response["namespace"]
+        assert desc.task_queue == response["task_queue"]
+        assert desc.status == response["status"]
+        assert desc.payload_codec == response["payload_codec"]
+        assert desc.input == response["input"]
+
     @pytest.mark.asyncio
     async def test_envelope_fields(self, client: Client) -> None:
         resp = _mock_response(200, {