Assert Python workflow task fail and history parity

Assert Python workflow task fail and history parity

Author: durable-workflow-ops

tests/fixtures/control-plane/workflow-task-fail-parity.json

@@ -0,0 +1,53 @@
+{
+  "schema": "durable-workflow.polyglot.control-plane-request-fixture",
+  "version": 1,
+  "operation": "workflow-task.fail",
+  "request": {
+    "method": "POST",
+    "path": "/worker/workflow-tasks/workflow-task-231/fail",
+    "body": {
+      "lease_owner": "polyglot-worker-231",
+      "workflow_task_attempt": 2,
+      "failure": {
+        "message": "non-deterministic command sequence",
+        "type": "NonDeterminism",
+        "stack_trace": "command 3 replay mismatch"
+      }
+    }
+  },
+  "semantic_body": {
+    "task_id": "workflow-task-231",
+    "lease_owner": "polyglot-worker-231",
+    "workflow_task_attempt": 2,
+    "message": "non-deterministic command sequence",
+    "outcome": "failed"
+  },
+  "response_body": {
+    "task_id": "workflow-task-231",
+    "workflow_task_attempt": 2,
+    "outcome": "failed",
+    "run_status": "running"
+  },
+  "cli": {
+    "argv": {
+      "task-id": "workflow-task-231",
+      "attempt": "2",
+      "--lease-owner": "polyglot-worker-231",
+      "--message": "non-deterministic command sequence",
+      "--type": "NonDeterminism",
+      "--stack-trace": "command 3 replay mismatch",
+      "--json": true
+    }
+  },
+  "sdk_python": {
+    "method": "fail_workflow_task",
+    "kwargs": {
+      "task_id": "workflow-task-231",
+      "lease_owner": "polyglot-worker-231",
+      "workflow_task_attempt": 2,
+      "message": "non-deterministic command sequence",
+      "failure_type": "NonDeterminism",
+      "stack_trace": "command 3 replay mismatch"
+    }
+  }
+}

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

@@ -0,0 +1,60 @@
+{
+  "schema": "durable-workflow.polyglot.control-plane-request-fixture",
+  "version": 1,
+  "operation": "workflow-task.history",
+  "request": {
+    "method": "POST",
+    "path": "/worker/workflow-tasks/workflow-task-231/history",
+    "body": {
+      "page_token": "history-page-2",
+      "lease_owner": "polyglot-worker-231",
+      "workflow_task_attempt": 2
+    }
+  },
+  "semantic_body": {
+    "task_id": "workflow-task-231",
+    "lease_owner": "polyglot-worker-231",
+    "workflow_task_attempt": 2,
+    "page_token": "history-page-2",
+    "last_sequence": 4,
+    "next_page_token": "history-page-3"
+  },
+  "response_body": {
+    "events": [
+      {
+        "event_id": 2,
+        "event_type": "ActivityScheduled",
+        "payload": {
+          "activity_type": "inventory.sync-page"
+        }
+      },
+      {
+        "event_id": 3,
+        "event_type": "ActivityCompleted",
+        "payload": {
+          "activity_id": "activity-231"
+        }
+      }
+    ],
+    "last_sequence": 4,
+    "next_page_token": "history-page-3"
+  },
+  "cli": {
+    "argv": {
+      "task-id": "workflow-task-231",
+      "page-token": "history-page-2",
+      "--lease-owner": "polyglot-worker-231",
+      "--attempt": "2",
+      "--json": true
+    }
+  },
+  "sdk_python": {
+    "method": "workflow_task_history",
+    "kwargs": {
+      "task_id": "workflow-task-231",
+      "page_token": "history-page-2",
+      "lease_owner": "polyglot-worker-231",
+      "workflow_task_attempt": 2
+    }
+  }
+}

tests/test_client.py

@@ -1461,6 +1461,34 @@ async def test_complete_workflow_task_matches_polyglot_fixture(self, client: Cli
         assert mock.call_args.args[:2] == (fixture["request"]["method"], f"/api{fixture['request']['path']}")
         assert mock.call_args.kwargs["json"] == fixture["request"]["body"]
 
+    @pytest.mark.asyncio
+    async def test_fail_workflow_task_matches_polyglot_fixture(self, client: Client) -> None:
+        fixture_path = Path(__file__).parent / "fixtures" / "control-plane" / "workflow-task-fail-parity.json"
+        fixture = json.loads(fixture_path.read_text())
+        resp = _mock_response(200, fixture["response_body"])
+
+        with patch.object(client._http, "request", new_callable=AsyncMock, return_value=resp) as mock:
+            result = await client.fail_workflow_task(**fixture["sdk_python"]["kwargs"])
+
+        assert result == fixture["response_body"]
+        assert result["outcome"] == fixture["semantic_body"]["outcome"]
+        assert mock.call_args.args[:2] == (fixture["request"]["method"], f"/api{fixture['request']['path']}")
+        assert mock.call_args.kwargs["json"] == fixture["request"]["body"]
+
+    @pytest.mark.asyncio
+    async def test_workflow_task_history_matches_polyglot_fixture(self, client: Client) -> None:
+        fixture_path = Path(__file__).parent / "fixtures" / "control-plane" / "workflow-task-history-parity.json"
+        fixture = json.loads(fixture_path.read_text())
+        resp = _mock_response(200, fixture["response_body"])
+
+        with patch.object(client._http, "request", new_callable=AsyncMock, return_value=resp) as mock:
+            page = await client.workflow_task_history(**fixture["sdk_python"]["kwargs"])
+
+        assert page == fixture["response_body"]
+        assert page["next_page_token"] == fixture["semantic_body"]["next_page_token"]
+        assert mock.call_args.args[:2] == (fixture["request"]["method"], f"/api{fixture['request']['path']}")
+        assert mock.call_args.kwargs["json"] == fixture["request"]["body"]
+
     @pytest.mark.asyncio
     async def test_body_shape(self, client: Client) -> None:
         resp = _mock_response(200, {"task_id": "t1", "outcome": "failed"})