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

fix(coverage_evaluator): KM 欄位修正 ke.body → ke.content + 擴大 title 匹配
Some checks failed
CD Pipeline / build-and-deploy (push) Has been cancelled
Details

Browse Source 
實測 df71c9a 部署後 coverage_evaluator 生效:
  - monitoring: 2 hosts match Prometheus targets
  - alerting: 74 筆 (22 green + 52 red)
  - km: 0 (錯誤: column "ke.body" does not exist)

真因: knowledge_entries 表欄位是 'content' 不是 'body'
修復: ke.content ILIKE '%name%' OR ke.title ILIKE '%name%'

同時清 unused import (typing.Any)

下輪 coverage_evaluator tick 將正確 UPDATE auto_km_creation 維度
解鎖完整 3 維 coverage (monitoring/alerting/km)

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>
This commit is contained in:
OG T
2026-04-19 17:24:46 +08:00
parent 92349bc37c
commit c8b263db06
1 changed files with 6 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
apps/api/src/jobs/coverage_evaluator_job.py
View File

@@ -27,7 +27,6 @@ from __future__ import annotations
import asyncio import asyncio
import json as _json import json as _json
import time as _time import time as _time
from typing import Any
import httpx import httpx
import structlog import structlog
@@ -253,27 +252,29 @@ async def _evaluate_alerting(run_id: str) -> int:
async def _evaluate_km_coverage(run_id: str) -> int: async def _evaluate_km_coverage(run_id: str) -> int:
""" """
asset 有對應 knowledge_entries → green asset 有對應 knowledge_entries → green
粗略: k8s_workload 看 app/namespace 是否有出現在 knowledge_entries.body.
2026-04-19 ogt + Claude Opus 4.7 v2 bug fix: knowledge_entries 欄位是 'content',
不是 'body' (前次 UndefinedColumnError). 同時加 title 匹配擴大覆蓋.
""" """
from sqlalchemy import text as _sql from sqlalchemy import text as _sql
from src.db.base import get_db_context from src.db.base import get_db_context
try: try:
async with get_db_context() as db: async with get_db_context() as db:
# 簡化: 只看 k8s_workload 是否有 app:name 字樣出現在 KM 裡
result = await db.execute( result = await db.execute(
_sql(""" _sql("""
UPDATE asset_coverage_snapshot cs UPDATE asset_coverage_snapshot cs
SET coverage_status = CASE SET coverage_status = CASE
WHEN ai.asset_type = 'k8s_workload' AND EXISTS ( WHEN ai.asset_type = 'k8s_workload' AND EXISTS (
SELECT 1 FROM knowledge_entries ke SELECT 1 FROM knowledge_entries ke
WHERE ke.body ILIKE '%' || ai.name || '%' WHERE ke.content ILIKE '%' || ai.name || '%'
OR ke.title ILIKE '%' || ai.name || '%'
) THEN 'green' ) THEN 'green'
WHEN ai.asset_type = 'k8s_workload' THEN 'yellow' WHEN ai.asset_type = 'k8s_workload' THEN 'yellow'
ELSE cs.coverage_status ELSE cs.coverage_status
END, END,
evidence = jsonb_build_object( evidence = jsonb_build_object(
'source', 'knowledge_entries_substring_match', 'source', 'knowledge_entries_content_or_title_match',
'asset_name', ai.name 'asset_name', ai.name
) )
FROM asset_inventory ai FROM asset_inventory ai