TD-P004: sdk-python missing schedule.history polyglot parity slice (#39)

Author: durable-workflow-ops

CHANGELOG.md

@@ -6,6 +6,18 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ## [Unreleased]
 
+### Changed
+- `tests/test_client.py` now closes the `schedule.history` polyglot
+  parity slice. `test_get_schedule_history_matches_polyglot_fixture`
+  asserts the full decoded payload envelope per event (`id`,
+  `recorded_at`, `payload`, plus the workflow attribution fields)
+  so the Python parity check covers the same wire content the CLI
+  parity check covers when it asserts the printed JSON envelope
+  matches the shared fixture's `response_body`. A companion
+  `test_iter_schedule_history_walks_polyglot_fixture` exercises
+  `Client.iter_schedule_history` against the shared fixture to lock
+  in the cursor-advance semantics across pages.
+
 ### Notes
 - Production-readiness validation is in progress for the first
   `1.0.0` release candidate. The 0.4.x line is feature-complete for

tests/test_client.py

@@ -1885,6 +1885,45 @@ async def test_get_schedule_history_matches_polyglot_fixture(self, client: Clien
             assert matching[0].workflow_instance_id == expected_refs["workflow_instance_id"]
             assert matching[0].workflow_run_id == expected_refs["workflow_run_id"]
 
+        wire_events = fixture["response_body"]["events"]
+        assert len(page.events) == len(wire_events)
+        for parsed, wire in zip(page.events, wire_events):
+            assert parsed.id == wire["id"]
+            assert parsed.sequence == wire["sequence"]
+            assert parsed.event_type == wire["event_type"]
+            assert parsed.recorded_at == wire["recorded_at"]
+            assert parsed.workflow_instance_id == wire["workflow_instance_id"]
+            assert parsed.workflow_run_id == wire["workflow_run_id"]
+            assert parsed.payload == wire["payload"]
+
+    @pytest.mark.asyncio
+    async def test_iter_schedule_history_walks_polyglot_fixture(self, client: Client) -> None:
+        fixture_path = Path(__file__).parent / "fixtures" / "control-plane" / "schedule-history-parity.json"
+        fixture = json.loads(fixture_path.read_text())
+        sdk = fixture["sdk_python"]
+        wire_events = fixture["response_body"]["events"]
+
+        first_page = dict(fixture["response_body"])
+        last_sequence = wire_events[-1]["sequence"]
+        terminal_page = {
+            "schedule_id": fixture["response_body"]["schedule_id"],
+            "namespace": fixture["response_body"].get("namespace"),
+            "events": [],
+            "has_more": False,
+            "next_cursor": None,
+        }
+        responses = [_mock_response(200, first_page), _mock_response(200, terminal_page)]
+
+        mock = AsyncMock(side_effect=responses)
+        with patch.object(client._http, "request", new=mock):
+            collected = [event async for event in client.iter_schedule_history(**sdk["args"])]
+
+        assert [event.sequence for event in collected] == [event["sequence"] for event in wire_events]
+        assert [event.event_type for event in collected] == [event["event_type"] for event in wire_events]
+        assert mock.call_count == 2
+        second_path = mock.call_args_list[1].args[1]
+        assert f"after_sequence={last_sequence}" in second_path
+
     @staticmethod
     def _schedule_spec(data: dict) -> ScheduleSpec:
         return ScheduleSpec(