[cross-repo from server#351] Conformance blocker: complete namespaces parity coverage (#145)

Author: durable-workflow-ops

CHANGELOG.md

@@ -6,6 +6,11 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ## [Unreleased]
 
+### Added
+- `Client.delete_namespace()` now exercises the namespace lifecycle cleanup
+  control-plane surface and returns the server's per-table cleanup counts on
+  `NamespaceDescription.deleted`.
+
 ### Fixed
 - Python parent workflows now decode successful child workflow completions from
   the server's documented `ChildRunCompleted.output` history payload, while

CONFORMANCE.md

@@ -25,7 +25,7 @@ The Python SDK claims two targets from the suite's matrix:
 | --- | --- | --- |
 | `control_plane_request_response` | `tests/fixtures/control-plane/` | stable, parity-shared with `cli` |
 | `signal_query_runtime_contract` | `tests/test_signals.py`, `tests/test_queries.py`, `tests/test_worker.py` and the public scenario manifest at <https://durable-workflow.github.io/platform-conformance/signal-query-runtime-scenarios.json> | stable, parity-shared with PHP worker, CLI, and server routes |
-| `namespace_runtime_contract` | public scenario manifest at <https://durable-workflow.github.io/platform-conformance/namespace-runtime-scenarios.json> | stable, suite v7 runtime coverage for namespace isolation and SDK namespace selection |
+| `namespace_runtime_contract` | public scenario manifest at <https://durable-workflow.github.io/platform-conformance/namespace-runtime-scenarios.json> | stable, suite v8 runtime coverage for namespace isolation and SDK namespace selection |
 | `child_workflow_runtime_contract` | public scenario manifest at <https://durable-workflow.github.io/platform-conformance/child-workflow-runtime-scenarios.json> | stable, parity-shared with PHP worker and server child-workflow runtime behavior |
 | `worker_task_lifecycle` | `tests/fixtures/external-task-input/`, `tests/fixtures/external-task-result/` | stable |
 | `history_replay_bundles` | `tests/fixtures/golden_history/` and the public replay scenario manifest at <https://durable-workflow.github.io/platform-conformance/replay-runtime-scenarios.json> | stable, parity-shared with `workflow` golden bundles and the full runtime replay scenario matrix |
@@ -55,7 +55,7 @@ result document before tag, with the conformance level at `full` or
 | Field | Value |
 | --- | --- |
 | Required claimed targets | `official_sdk`, `worker_protocol_implementation` |
-| Required suite version | `PlatformConformanceSuite::VERSION` (currently `7`, mirrored at `/platform-conformance-contract.json`) |
+| Required suite version | `PlatformConformanceSuite::VERSION` (currently `8`, mirrored at `/platform-conformance-contract.json`) |
 | CI job | `platform-conformance` (lands when the harness reference implementation publishes; until then `cli-parity` and `test_history_event_contract.py` cover the same ground) |
 | Block on `nonconforming` | yes |
 | Artifact attached to release | harness result document, schema `durable-workflow.v2.platform-conformance.result` |

src/durable_workflow/client.py

@@ -148,13 +148,21 @@ class NamespaceDescription:
     status: str | None = None
     created_at: str | None = None
     updated_at: str | None = None
+    deleted: dict[str, int] | None = None
     external_payload_storage: ExternalPayloadStoragePolicy | None = None
 
     @classmethod
     def from_dict(cls, data: dict[str, Any]) -> NamespaceDescription:
         external_payload_storage = None
         if isinstance(data.get("external_payload_storage"), dict):
             external_payload_storage = ExternalPayloadStoragePolicy.from_dict(data)
+        deleted = None
+        if isinstance(data.get("deleted"), dict):
+            deleted = {
+                str(key): value
+                for key, value in data["deleted"].items()
+                if isinstance(value, int)
+            }
 
         return cls(
             name=str(data.get("name", "")),
@@ -163,6 +171,7 @@ def from_dict(cls, data: dict[str, Any]) -> NamespaceDescription:
             status=data.get("status"),
             created_at=data.get("created_at"),
             updated_at=data.get("updated_at"),
+            deleted=deleted,
             external_payload_storage=external_payload_storage,
         )
 
@@ -1572,6 +1581,19 @@ async def update_namespace(
             )
         return NamespaceDescription.from_dict(data)
 
+    async def delete_namespace(self, name: str) -> NamespaceDescription:
+        """Delete a namespace through the server lifecycle surface."""
+        data = await self._request("DELETE", f"/namespaces/{quote(name, safe='')}", context=name)
+        if not isinstance(data, dict):
+            raise ServerError(
+                200,
+                {
+                    "reason": "invalid_namespace_response",
+                    "message": f"expected JSON object, got {type(data).__name__}",
+                },
+            )
+        return NamespaceDescription.from_dict(data)
+
     async def set_namespace_external_storage(
         self,
         name: str | None = None,

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

@@ -0,0 +1,40 @@
+{
+  "schema": "durable-workflow.polyglot.control-plane-request-fixture",
+  "version": 1,
+  "operation": "namespace.delete",
+  "request": {
+    "method": "DELETE",
+    "path": "/namespaces/billing"
+  },
+  "cli": {
+    "argv": {
+      "name": "billing",
+      "--json": true
+    }
+  },
+  "sdk_python": {
+    "args": {
+      "name": "billing"
+    }
+  },
+  "response_body": {
+    "name": "billing",
+    "status": "deleted",
+    "deleted": {
+      "workflow_runs": 2,
+      "workflow_schedules": 1,
+      "search_attribute_definitions": 3,
+      "workflow_worker_registrations": 1
+    }
+  },
+  "semantic_body": {
+    "name": "billing",
+    "status": "deleted",
+    "deleted_keys": [
+      "workflow_runs",
+      "workflow_schedules",
+      "search_attribute_definitions",
+      "workflow_worker_registrations"
+    ]
+  }
+}

tests/test_client.py

@@ -1080,6 +1080,21 @@ async def test_update_namespace_matches_polyglot_fixture(self, client: Client) -
         assert result.description == fixture["semantic_body"]["description"]
         assert result.retention_days == fixture["semantic_body"]["retention_days"]
 
+    @pytest.mark.asyncio
+    async def test_delete_namespace_matches_polyglot_fixture(self, client: Client) -> None:
+        fixture_path = Path(__file__).parent / "fixtures" / "control-plane" / "namespace-delete-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.delete_namespace(**fixture["sdk_python"]["args"])
+
+        assert mock.call_args.args[:2] == (fixture["request"]["method"], f"/api{fixture['request']['path']}")
+        assert result.name == fixture["semantic_body"]["name"]
+        assert result.status == fixture["semantic_body"]["status"]
+        assert result.deleted is not None
+        assert sorted(result.deleted) == sorted(fixture["semantic_body"]["deleted_keys"])
+
     @pytest.mark.asyncio
     async def test_set_namespace_external_storage_matches_polyglot_fixture(self, client: Client) -> None:
         fixture_path = Path(__file__).parent / "fixtures" / "control-plane" / "namespace-set-storage-driver-parity.json"