Expose server dispatch admission budgets in Python SDK task-queue visibility

Expose dispatch admission fields in Python SDK

Author: durable-workflow-ops

README.md

@@ -171,6 +171,11 @@ for queue in queues.task_queues:
     print(queue.name, workflow_admission.status if workflow_admission else "unknown")
 ```
 
+The workflow and activity admission objects expose both queue-level and
+namespace-level server budgets, including active lease caps and per-minute
+dispatch-rate limits, so automation can detect whether local worker slots,
+queue caps, or namespace caps are constraining throughput.
+
 ## Replay captured histories
 
 Use `Replayer` to debug a captured history without connecting to a live server:

src/durable_workflow/client.py

@@ -118,6 +118,15 @@ class TaskQueueTaskAdmission:
     server_max_active_leases_per_queue: int | None = None
     server_active_lease_count: int | None = None
     server_remaining_active_lease_capacity: int | None = None
+    server_max_active_leases_per_namespace: int | None = None
+    server_namespace_active_lease_count: int | None = None
+    server_remaining_namespace_active_lease_capacity: int | None = None
+    server_max_dispatches_per_minute: int | None = None
+    server_dispatch_count_this_minute: int | None = None
+    server_remaining_dispatch_capacity: int | None = None
+    server_max_dispatches_per_minute_per_namespace: int | None = None
+    server_namespace_dispatch_count_this_minute: int | None = None
+    server_remaining_namespace_dispatch_capacity: int | None = None
     server_lock_required: bool | None = None
     server_lock_supported: bool | None = None
 
@@ -137,6 +146,19 @@ def from_dict(cls, data: dict[str, Any] | None) -> TaskQueueTaskAdmission | None
             server_max_active_leases_per_queue=data.get("server_max_active_leases_per_queue"),
             server_active_lease_count=data.get("server_active_lease_count"),
             server_remaining_active_lease_capacity=data.get("server_remaining_active_lease_capacity"),
+            server_max_active_leases_per_namespace=data.get("server_max_active_leases_per_namespace"),
+            server_namespace_active_lease_count=data.get("server_namespace_active_lease_count"),
+            server_remaining_namespace_active_lease_capacity=data.get(
+                "server_remaining_namespace_active_lease_capacity"
+            ),
+            server_max_dispatches_per_minute=data.get("server_max_dispatches_per_minute"),
+            server_dispatch_count_this_minute=data.get("server_dispatch_count_this_minute"),
+            server_remaining_dispatch_capacity=data.get("server_remaining_dispatch_capacity"),
+            server_max_dispatches_per_minute_per_namespace=data.get(
+                "server_max_dispatches_per_minute_per_namespace"
+            ),
+            server_namespace_dispatch_count_this_minute=data.get("server_namespace_dispatch_count_this_minute"),
+            server_remaining_namespace_dispatch_capacity=data.get("server_remaining_namespace_dispatch_capacity"),
             server_lock_required=data.get("server_lock_required"),
             server_lock_supported=data.get("server_lock_supported"),
         )

tests/test_client.py

@@ -383,6 +383,15 @@ async def test_list_task_queues_parses_admission(self, client: Client) -> None:
                             "server_max_active_leases_per_queue": 1,
                             "server_active_lease_count": 1,
                             "server_remaining_active_lease_capacity": 0,
+                            "server_max_active_leases_per_namespace": 8,
+                            "server_namespace_active_lease_count": 7,
+                            "server_remaining_namespace_active_lease_capacity": 1,
+                            "server_max_dispatches_per_minute": 60,
+                            "server_dispatch_count_this_minute": 60,
+                            "server_remaining_dispatch_capacity": 0,
+                            "server_max_dispatches_per_minute_per_namespace": 240,
+                            "server_namespace_dispatch_count_this_minute": 200,
+                            "server_remaining_namespace_dispatch_capacity": 40,
                             "server_lock_required": True,
                             "server_lock_supported": True,
                         },
@@ -412,6 +421,15 @@ async def test_list_task_queues_parses_admission(self, client: Client) -> None:
             assert queue.admission.workflow_tasks is not None
             assert queue.admission.workflow_tasks.status == "throttled"
             assert queue.admission.workflow_tasks.server_remaining_active_lease_capacity == 0
+            assert queue.admission.workflow_tasks.server_max_active_leases_per_namespace == 8
+            assert queue.admission.workflow_tasks.server_namespace_active_lease_count == 7
+            assert queue.admission.workflow_tasks.server_remaining_namespace_active_lease_capacity == 1
+            assert queue.admission.workflow_tasks.server_max_dispatches_per_minute == 60
+            assert queue.admission.workflow_tasks.server_dispatch_count_this_minute == 60
+            assert queue.admission.workflow_tasks.server_remaining_dispatch_capacity == 0
+            assert queue.admission.workflow_tasks.server_max_dispatches_per_minute_per_namespace == 240
+            assert queue.admission.workflow_tasks.server_namespace_dispatch_count_this_minute == 200
+            assert queue.admission.workflow_tasks.server_remaining_namespace_dispatch_capacity == 40
             assert queue.admission.activity_tasks is not None
             assert queue.admission.activity_tasks.configured_slot_count == 5
             assert queue.admission.query_tasks is not None