Assert Python schedule control-plane parity

Assert Python schedule control parity

Author: durable-workflow-ops

tests/fixtures/control-plane/schedule-delete-parity.json

@@ -0,0 +1,32 @@
+{
+  "schema": "durable-workflow.polyglot.control-plane-request-fixture",
+  "version": 1,
+  "operation": "schedule.delete",
+  "request": {
+    "method": "DELETE",
+    "path": "/schedules/inventory-refresh"
+  },
+  "semantic_body": {
+    "namespace": "orders-prod",
+    "schedule_id": "inventory-refresh",
+    "outcome": "deleted"
+  },
+  "response_body": {
+    "namespace": "orders-prod",
+    "schedule_id": "inventory-refresh",
+    "outcome": "deleted",
+    "deleted_at": "2026-04-22T07:30:00Z"
+  },
+  "cli": {
+    "argv": {
+      "schedule-id": "inventory-refresh",
+      "--json": true
+    }
+  },
+  "sdk_python": {
+    "method": "delete_schedule",
+    "args": {
+      "schedule_id": "inventory-refresh"
+    }
+  }
+}

tests/fixtures/control-plane/schedule-pause-parity.json

@@ -0,0 +1,40 @@
+{
+  "schema": "durable-workflow.polyglot.control-plane-request-fixture",
+  "version": 1,
+  "operation": "schedule.pause",
+  "request": {
+    "method": "POST",
+    "path": "/schedules/daily-order-rollup/pause",
+    "body": {
+      "note": "operator maintenance window"
+    }
+  },
+  "semantic_body": {
+    "namespace": "orders-prod",
+    "schedule_id": "daily-order-rollup",
+    "outcome": "paused",
+    "note": "operator maintenance window"
+  },
+  "response_body": {
+    "namespace": "orders-prod",
+    "schedule_id": "daily-order-rollup",
+    "outcome": "paused",
+    "paused": true,
+    "note": "operator maintenance window",
+    "paused_at": "2026-04-22T07:00:00Z"
+  },
+  "cli": {
+    "argv": {
+      "schedule-id": "daily-order-rollup",
+      "--note": "operator maintenance window",
+      "--json": true
+    }
+  },
+  "sdk_python": {
+    "method": "pause_schedule",
+    "args": {
+      "schedule_id": "daily-order-rollup",
+      "note": "operator maintenance window"
+    }
+  }
+}

tests/fixtures/control-plane/schedule-resume-parity.json

@@ -0,0 +1,40 @@
+{
+  "schema": "durable-workflow.polyglot.control-plane-request-fixture",
+  "version": 1,
+  "operation": "schedule.resume",
+  "request": {
+    "method": "POST",
+    "path": "/schedules/daily-order-rollup/resume",
+    "body": {
+      "note": "maintenance complete"
+    }
+  },
+  "semantic_body": {
+    "namespace": "orders-prod",
+    "schedule_id": "daily-order-rollup",
+    "outcome": "resumed",
+    "note": "maintenance complete"
+  },
+  "response_body": {
+    "namespace": "orders-prod",
+    "schedule_id": "daily-order-rollup",
+    "outcome": "resumed",
+    "paused": false,
+    "note": "maintenance complete",
+    "resumed_at": "2026-04-22T07:15:00Z"
+  },
+  "cli": {
+    "argv": {
+      "schedule-id": "daily-order-rollup",
+      "--note": "maintenance complete",
+      "--json": true
+    }
+  },
+  "sdk_python": {
+    "method": "resume_schedule",
+    "args": {
+      "schedule_id": "daily-order-rollup",
+      "note": "maintenance complete"
+    }
+  }
+}

tests/test_client.py

@@ -1111,6 +1111,48 @@ async def test_describe_schedule_matches_polyglot_fixture(self, client: Client)
         assert result.fires_count == semantic["fires_count"]
         assert result.remaining_actions == semantic["remaining_actions"]
 
+    @pytest.mark.asyncio
+    async def test_pause_schedule_matches_polyglot_fixture(self, client: Client) -> None:
+        fixture_path = Path(__file__).parent / "fixtures" / "control-plane" / "schedule-pause-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:
+            await client.pause_schedule(**sdk["args"])
+
+        assert mock.call_args.args[0] == fixture["request"]["method"]
+        assert mock.call_args.args[1] == f"/api{fixture['request']['path']}"
+        assert mock.call_args.kwargs["json"] == fixture["request"]["body"]
+
+    @pytest.mark.asyncio
+    async def test_resume_schedule_matches_polyglot_fixture(self, client: Client) -> None:
+        fixture_path = Path(__file__).parent / "fixtures" / "control-plane" / "schedule-resume-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:
+            await client.resume_schedule(**sdk["args"])
+
+        assert mock.call_args.args[0] == fixture["request"]["method"]
+        assert mock.call_args.args[1] == f"/api{fixture['request']['path']}"
+        assert mock.call_args.kwargs["json"] == fixture["request"]["body"]
+
+    @pytest.mark.asyncio
+    async def test_delete_schedule_matches_polyglot_fixture(self, client: Client) -> None:
+        fixture_path = Path(__file__).parent / "fixtures" / "control-plane" / "schedule-delete-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:
+            await client.delete_schedule(**sdk["args"])
+
+        assert mock.call_args.args[0] == fixture["request"]["method"]
+        assert mock.call_args.args[1] == f"/api{fixture['request']['path']}"
+        assert mock.call_args.kwargs.get("json") is None
+
 
 class TestErrorMapping:
     @pytest.mark.asyncio