feat(ops): carry stock readbacks into reboot slo
All checks were successful
CD Pipeline / workflow-shape (push) Successful in 0s
CD Pipeline / cancel-stale-cd (push) Has been skipped
CD Pipeline / tests (push) Successful in 24s
CD Pipeline / build-and-deploy (push) Successful in 4m33s
CD Pipeline / post-deploy-checks (push) Successful in 56s

This commit is contained in:
Your Name
2026-06-30 00:00:28 +08:00
parent 29e32a07a8
commit c32fab9cb4
8 changed files with 203 additions and 17 deletions

View File

@@ -192,7 +192,7 @@ def test_delivery_closure_workbench_exposes_p0_006_reboot_slo_lane():
assert lane["metric"]["stockplatform_ingestion_status"] == "ok"
assert lane["metric"]["stockplatform_freshness_blocker_count"] == 0
assert lane["metric"]["stockplatform_ingestion_blocker_count"] == 0
assert lane["metric"]["stockplatform_final_retry_window_passed"] is False
assert lane["metric"]["stockplatform_final_retry_window_passed"] is True
assert lane["metric"]["stockplatform_controlled_recovery_gate_required"] is False
assert lane["metric"]["host_reboot_performed"] is False
assert lane["metric"]["service_restart_performed"] is False
@@ -245,7 +245,7 @@ def _assert_delivery_workbench_shape(data: dict):
data["summary"][
"reboot_auto_recovery_stockplatform_final_retry_window_passed"
]
is False
is True
)
assert (
data["summary"][

View File

@@ -101,7 +101,7 @@ def _assert_reboot_slo_payload(payload: dict):
assert payload["rollups"]["stockplatform_ingestion_status"] == "ok"
assert payload["rollups"]["stockplatform_freshness_blocker_count"] == 0
assert payload["rollups"]["stockplatform_ingestion_blocker_count"] == 0
assert payload["rollups"]["stockplatform_final_retry_window_passed"] is False
assert payload["rollups"]["stockplatform_final_retry_window_passed"] is True
assert (
payload["rollups"]["stockplatform_controlled_recovery_gate_required"]
is False
@@ -114,12 +114,16 @@ def _assert_reboot_slo_payload(payload: dict):
assert stockplatform["ingestion_blockers"] == []
assert stockplatform["margin_short_recovery"]["status"] == "recovered"
assert stockplatform["margin_short_recovery"]["successful_source_run_ids"] == [
3390,
3389,
3390,
]
assert stockplatform["ai_recommendations_recovery"]["status"] == "recovered"
assert stockplatform["eod_window"]["final_retry_window_passed"] is False
assert stockplatform["eod_window"]["final_retry_window_passed"] is True
assert stockplatform["controlled_recovery_gate"]["required"] is False
assert (
stockplatform["controlled_recovery_gate"]["status"]
== "not_required_freshness_recovered"
)
assert "manual_db_update" in stockplatform["controlled_recovery_gate"][
"forbidden_actions"
]