wooo/awoooi
1
1
Fork 0
Code Issues 2 Pull Requests 1 Actions 3 Packages Projects Releases Wiki Activity

feat(delivery): expose queue verifier contract

Browse Source
This commit is contained in:
Your Name
2026-06-29 09:38:21 +08:00
parent 69682e4c32
commit 76071f21a8
5 changed files with 93 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

39
apps/api/src/services/delivery_closure_workbench.py
View File

@@ -192,6 +192,12 @@ def build_delivery_closure_workbench(
)
or ""
),
"latest_visible_waiting_runner_kind": str(
production_deploy_readback.get(
"latest_visible_waiting_runner_kind"
)
or ""
),
"latest_visible_waiting_runner_status": str(
production_deploy_readback.get(
"latest_visible_waiting_runner_status"
@@ -204,6 +210,18 @@ def build_delivery_closure_workbench(
)
or ""
),
"public_actions_queue_readback_schema_version": str(
production_deploy_readback.get(
"public_actions_queue_readback_schema_version"
)
or ""
),
"public_actions_queue_readback_verifier": str(
production_deploy_readback.get(
"public_actions_queue_readback_verifier"
)
or ""
),
"non110_runner_ready": production_deploy_readback.get(
"non110_runner_ready"
)
@@ -258,6 +276,10 @@ def build_delivery_closure_workbench(
"non110_runner_ready_registration_count"
)
),
"non110_runner_safe_next_step": str(
production_deploy_readback.get("non110_runner_safe_next_step")
or ""
),
"non110_runner_remaining_blocker_count": len(
_strings(
production_deploy_readback.get(
@@ -496,6 +518,10 @@ def build_delivery_closure_workbench(
)
or ""
),
"production_deploy_latest_visible_waiting_runner_kind": str(
production_deploy_readback.get("latest_visible_waiting_runner_kind")
or ""
),
"production_deploy_latest_visible_waiting_runner_status": str(
production_deploy_readback.get("latest_visible_waiting_runner_status")
or ""
@@ -504,6 +530,16 @@ def build_delivery_closure_workbench(
production_deploy_readback.get("latest_visible_waiting_runner_label")
or ""
),
"production_deploy_public_actions_queue_readback_schema_version": str(
production_deploy_readback.get(
"public_actions_queue_readback_schema_version"
)
or ""
),
"production_deploy_public_actions_queue_readback_verifier": str(
production_deploy_readback.get("public_actions_queue_readback_verifier")
or ""
),
"production_deploy_non110_runner_ready": production_deploy_readback.get(
"non110_runner_ready"
)
@@ -560,6 +596,9 @@ def build_delivery_closure_workbench(
"non110_runner_ready_registration_count"
)
),
"production_deploy_non110_runner_safe_next_step": str(
production_deploy_readback.get("non110_runner_safe_next_step") or ""
),
"production_deploy_non110_runner_remaining_blocker_count": len(
_strings(
production_deploy_readback.get(

36
apps/api/tests/test_delivery_closure_workbench_api.py
View File

@@ -71,6 +71,10 @@ def test_delivery_closure_workbench_endpoint_returns_product_summary():
data["summary"]["production_deploy_latest_visible_waiting_runner_workflow"]
== "ai-technology-watch.yaml"
)
assert (
data["summary"]["production_deploy_latest_visible_waiting_runner_kind"]
== "Scheduled"
)
assert (
data["summary"]["production_deploy_latest_visible_waiting_runner_status"]
== "No matching online runner with label: awoooi-non110-ubuntu"
@@ -79,6 +83,16 @@ def test_delivery_closure_workbench_endpoint_returns_product_summary():
data["summary"]["production_deploy_latest_visible_waiting_runner_label"]
== "awoooi-non110-ubuntu"
)
assert (
data["summary"][
"production_deploy_public_actions_queue_readback_schema_version"
]
== "awoooi_public_gitea_actions_queue_readback_v1"
)
assert (
data["summary"]["production_deploy_public_actions_queue_readback_verifier"]
== "ops/runner/read-public-gitea-actions-queue.py --json"
)
assert data["summary"]["production_deploy_non110_runner_ready"] is False
assert (
data["summary"][
@@ -130,6 +144,9 @@ def test_delivery_closure_workbench_endpoint_returns_product_summary():
data["summary"]["production_deploy_non110_runner_ready_registration_count"]
== 0
)
assert data["summary"]["production_deploy_non110_runner_safe_next_step"] == (
"run_register_awoooi_non110_runner_script_without_printing_token_then_autostart_path_will_enable_service_and_rerun_this_verifier"
)
assert (
data["summary"]["production_deploy_non110_runner_remaining_blocker_count"]
== 3
@@ -177,7 +194,7 @@ def test_delivery_closure_workbench_endpoint_returns_product_summary():
assert lanes["production_deploy"]["blocker_count"] == 4
assert lanes["production_deploy"]["metric"][
"observed_source_control_main_short_sha"
] == "f84269453834"
] == "c53cbca4a26d"
assert lanes["production_deploy"]["metric"][
"production_image_tag_short_sha"
] == "af45811e87"
@@ -235,6 +252,10 @@ def test_delivery_closure_workbench_endpoint_returns_product_summary():
]
== "ai-technology-watch.yaml"
)
assert (
lanes["production_deploy"]["metric"]["latest_visible_waiting_runner_kind"]
== "Scheduled"
)
assert (
lanes["production_deploy"]["metric"][
"latest_visible_waiting_runner_status"
@@ -245,6 +266,16 @@ def test_delivery_closure_workbench_endpoint_returns_product_summary():
lanes["production_deploy"]["metric"]["latest_visible_waiting_runner_label"]
== "awoooi-non110-ubuntu"
)
assert (
lanes["production_deploy"]["metric"][
"public_actions_queue_readback_schema_version"
]
== "awoooi_public_gitea_actions_queue_readback_v1"
)
assert (
lanes["production_deploy"]["metric"]["public_actions_queue_readback_verifier"]
== "ops/runner/read-public-gitea-actions-queue.py --json"
)
assert lanes["production_deploy"]["metric"]["non110_runner_ready"] is False
assert (
lanes["production_deploy"]["metric"][
@@ -300,6 +331,9 @@ def test_delivery_closure_workbench_endpoint_returns_product_summary():
]
== 0
)
assert lanes["production_deploy"]["metric"]["non110_runner_safe_next_step"] == (
"run_register_awoooi_non110_runner_script_without_printing_token_then_autostart_path_will_enable_service_and_rerun_this_verifier"
)
assert (
lanes["production_deploy"]["metric"][
"non110_runner_remaining_blocker_count"