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

fix(reboot): sync service backup readback overlay
Some checks failed
CD Pipeline / workflow-shape (push) Successful in 0s
Details
CD Pipeline / cancel-stale-cd (push) Has been skipped
Details
CD Pipeline / tests (push) Successful in 1m0s
Details
CD Pipeline / post-deploy-checks (push) Has been cancelled
Details
CD Pipeline / build-and-deploy (push) Has been cancelled
Details

Browse Source
This commit is contained in:
Your Name
2026-07-03 10:16:52 +08:00
parent 5bde567dc0
commit 2fd90ad98a
2 changed files with 64 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

46
apps/api/src/services/reboot_auto_recovery_slo_scorecard.py
View File

@@ -991,6 +991,7 @@ def _apply_prometheus_service_backup_boolean_readback(
rollups["controlled_service_data_backup_can_clear_blockers"] = not blocking_fields
rollups["controlled_service_data_backup_readback_status"] = service_backup["status"]
rollups["runtime_metric_service_backup_boolean_overlay_applied"] = True
_sync_controlled_service_data_backup_readback_fields(payload)
def _apply_prometheus_metric_active_blockers(
@@ -1306,6 +1307,51 @@ def apply_stockplatform_runtime_readback(
rollups["controlled_service_data_backup_blocker_count"] = blocker_count
rollups["controlled_service_data_backup_can_clear_blockers"] = can_clear
rollups["controlled_service_data_backup_readback_status"] = service_backup["status"]
_sync_controlled_service_data_backup_readback_fields(payload)
def _sync_controlled_service_data_backup_readback_fields(
payload: dict[str, Any],
) -> None:
service_backup = _dict(
payload.setdefault("controlled_service_data_backup_readback", {})
)
blocking_fields = _strings(service_backup.get("blocking_fields"))
blocker_count = _int(
service_backup.get("controlled_service_data_backup_blocker_count")
)
if blocker_count == 0 and blocking_fields:
blocker_count = len(blocking_fields)
readback_present = service_backup.get("readback_present") is True
can_clear = readback_present and blocker_count == 0
status = (
"ready_service_data_backup_green"
if can_clear
else "blocked_service_data_backup_readback_not_green"
)
next_safe_action = (
"keep_timer_live_wait_for_fresh_all_host_reboot_event_or_drill_preflight"
if can_clear
else "collect_public_service_data_backup_readback_and_refresh_reboot_slo_scorecard_no_reboot_no_db_write"
)
service_backup["status"] = status
service_backup["can_clear_service_data_backup_blockers"] = can_clear
service_backup["controlled_service_data_backup_blocker_count"] = blocker_count
service_backup["next_safe_action"] = next_safe_action
readback = _dict(payload.setdefault("readback", {}))
readback["controlled_service_data_backup_readback_present"] = readback_present
readback["controlled_service_data_backup_readback_status"] = status
readback["controlled_service_data_backup_blocker_count"] = blocker_count
readback["controlled_service_data_backup_next_safe_action"] = next_safe_action
rollups = _dict(payload.setdefault("rollups", {}))
rollups["controlled_service_data_backup_readback_present"] = readback_present
rollups["controlled_service_data_backup_readback_status"] = status
rollups["controlled_service_data_backup_blocker_count"] = blocker_count
rollups["controlled_service_data_backup_can_clear_blockers"] = can_clear
rollups["controlled_service_data_backup_next_safe_action"] = next_safe_action
def _append_live_stockplatform_blockers(