feat(recovery): classify non110 harbor repair lane blocker
Some checks failed
CD Pipeline / workflow-shape (push) Has been cancelled
CD Pipeline / cancel-stale-cd (push) Has been cancelled
CD Pipeline / tests (push) Has been cancelled
CD Pipeline / build-and-deploy (push) Has been cancelled
CD Pipeline / post-deploy-checks (push) Has been cancelled
AWOOOI Harbor 110 Local Repair / workflow-shape (push) Successful in 0s
AWOOOI Harbor 110 Local Repair / harbor-110-local-repair (push) Has been cancelled

This commit is contained in:
Your Name
2026-07-01 08:25:35 +08:00
parent 40b2742456
commit 77e0b58ee4
4 changed files with 252 additions and 0 deletions

View File

@@ -689,6 +689,50 @@ def test_harbor_recovery_receipt_surfaces_inflight_cd_harbor_retry() -> None:
assert payload["rollups"]["gitea_queue_blocker_count"] == 3
def test_harbor_recovery_receipt_surfaces_non110_cd_repair_lane_blocker() -> None:
payload = validate_harbor_registry_controlled_recovery_receipt(
{
"gitea_actions_queue_readback": (
_gitea_queue_cd_harbor_repair_requires_110_lane()
),
}
)
assert (
"gitea_queue_cd_harbor_repair_blocked_by_no_matching_awoooi_host"
in payload["active_blockers"]
)
assert (
"gitea_queue_cd_harbor_repair_requires_110_controlled_lane"
in payload["active_blockers"]
)
queue = payload["readback"]["gitea_actions_queue"]
assert queue["current_cd_harbor_repair_requires_110_controlled_lane"] is True
assert (
queue["current_cd_harbor_repair_blocked_by_no_matching_awoooi_host"]
is True
)
assert queue["current_cd_harbor_repair_lane_classifier"] == (
"cd_harbor_repair_requires_110_controlled_lane_no_matching_awoooi_host"
)
readiness = payload["readback"]["control_path_readiness"]
assert (
"gitea_queue_cd_harbor_repair_blocked_by_no_matching_awoooi_host"
in readiness["signal_ids"]
)
assert (
"gitea_queue_cd_harbor_repair_requires_110_controlled_lane"
in readiness["signal_ids"]
)
assert payload["rollups"][
"gitea_queue_current_cd_harbor_repair_requires_110_controlled_lane"
] is True
assert (
payload["rollups"]["gitea_queue_current_cd_harbor_repair_lane_classifier"]
== "cd_harbor_repair_requires_110_controlled_lane_no_matching_awoooi_host"
)
def test_harbor_recovery_receipt_endpoint_redacts_raw_output() -> None:
app = FastAPI()
app.include_router(router, prefix="/api/v1")
@@ -1034,3 +1078,26 @@ def _gitea_queue_no_matching_runner_with_cd_retry() -> dict:
}
)
return payload
def _gitea_queue_cd_harbor_repair_requires_110_lane() -> dict:
payload = _gitea_queue_no_matching_runner()
payload["readback"].update(
{
"latest_visible_cd_harbor_repair_requires_110_controlled_lane": True,
"latest_visible_cd_harbor_repair_blocked_by_no_matching_awoooi_host": True,
"latest_visible_cd_harbor_repair_lane_classifier": (
"cd_harbor_repair_requires_110_controlled_lane_no_matching_awoooi_host"
),
}
)
payload["rollups"].update(
{
"current_main_cd_harbor_repair_requires_110_controlled_lane": True,
"current_main_cd_harbor_repair_blocked_by_no_matching_awoooi_host": True,
"current_main_cd_harbor_repair_lane_classifier": (
"cd_harbor_repair_requires_110_controlled_lane_no_matching_awoooi_host"
),
}
)
return payload