From 5cd8d8c7e1455d69b9c3791cc6904e89419fd9db Mon Sep 17 00:00:00 2001 From: lda Date: Wed, 9 Sep 2026 19:22:05 +0700 Subject: [PATCH] fix: expose admitted run filter over RPC --- src/wf_transport_rpc_http/models.py | 2 +- tests/wf_transport_rpc_http/test_schedules_rpc.py | 6 ++++++ 2 files changed, 7 insertions(+), 1 deletion(-) diff --git a/src/wf_transport_rpc_http/models.py b/src/wf_transport_rpc_http/models.py index 8c1fe45a..0a408476 100644 --- a/src/wf_transport_rpc_http/models.py +++ b/src/wf_transport_rpc_http/models.py @@ -426,7 +426,7 @@ class ValidateDeploymentParams(RpcParamsModel): class ListRunsParams(RpcParamsModel): - status: Literal["completed", "failed", "interrupted"] | None = None + status: Literal["admitted", "completed", "failed", "interrupted"] | None = None cursor: str | None = None limit: int = Field(default=50, ge=1, le=100) diff --git a/tests/wf_transport_rpc_http/test_schedules_rpc.py b/tests/wf_transport_rpc_http/test_schedules_rpc.py index 43824e13..cba8c3ac 100644 --- a/tests/wf_transport_rpc_http/test_schedules_rpc.py +++ b/tests/wf_transport_rpc_http/test_schedules_rpc.py @@ -28,6 +28,7 @@ from wf_transport_rpc_http.client.schedules import RpcScheduleClientMixin from wf_transport_rpc_http.models import ( CreateScheduleParams, ListOccurrencesParams, + ListRunsParams, UpdateScheduleParams, ) @@ -36,6 +37,11 @@ def _cron() -> dict[str, Any]: return {"kind": "cron", "expression": "* * * * *", "timezone": "UTC"} +def test_rpc_list_runs_accepts_admitted_status() -> None: + """RPC validation exposes the API's admitted-run filter.""" + assert ListRunsParams(status="admitted").status == "admitted" + + def _constant_plan() -> RawWorkflowPlan: return RawWorkflowPlan.model_validate( {