Assert Python workflow history control-plane parity

Assert Python workflow history parity

Author: durable-workflow-ops

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

@@ -0,0 +1,52 @@
+{
+  "schema": "durable-workflow.polyglot.control-plane-request-fixture",
+  "version": 1,
+  "operation": "workflow.history",
+  "request": {
+    "method": "GET",
+    "path": "/workflows/wf-polyglot-231/runs/run-polyglot-231/history"
+  },
+  "semantic_body": {
+    "workflow_id": "wf-polyglot-231",
+    "run_id": "run-polyglot-231"
+  },
+  "response_body": {
+    "workflow_id": "wf-polyglot-231",
+    "run_id": "run-polyglot-231",
+    "events": [
+      {
+        "sequence": 1,
+        "event_type": "WorkflowStarted",
+        "timestamp": "2026-04-22T04:30:00Z",
+        "payload": {
+          "workflow_type": "orders.process",
+          "task_queue": "orders"
+        }
+      },
+      {
+        "sequence": 2,
+        "event_type": "ActivityScheduled",
+        "timestamp": "2026-04-22T04:30:01Z",
+        "payload": {
+          "activity_type": "reserve_inventory"
+        }
+      }
+    ]
+  },
+  "cli": {
+    "argv": {
+      "workflow-id": "wf-polyglot-231",
+      "run-id": "run-polyglot-231",
+      "--json": true
+    },
+    "expected_query": {
+      "wait_new_event": false
+    }
+  },
+  "sdk_python": {
+    "args": {
+      "workflow_id": "wf-polyglot-231",
+      "run_id": "run-polyglot-231"
+    }
+  }
+}

tests/test_client.py

@@ -321,6 +321,29 @@ async def test_not_found(self, client: Client) -> None:
             await client.describe_workflow("wf-missing")
 
 
+class TestGetHistory:
+    @pytest.mark.asyncio
+    async def test_history_request_matches_polyglot_fixture(self, client: Client) -> None:
+        fixture_path = Path(__file__).parent / "fixtures" / "control-plane" / "workflow-history-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:
+            history = await client.get_history(**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"]
+        assert sdk["args"]["workflow_id"] == semantic["workflow_id"]
+        assert sdk["args"]["run_id"] == semantic["run_id"]
+        assert history == fixture["response_body"]
+
+
 class TestSignalWorkflow:
     @pytest.mark.asyncio
     async def test_signal(self, client: Client) -> None: