fix: 修复 trigger.operator null + 添加覆盖反馈重试 - Closes #22, Closes #21
CI / test (pull_request) Successful in 7s

#22: _normalize_rule 补充 trigger 级别 operator (AND/OR) 默认值
#21: step1 验证失败时自动生成覆盖反馈并重试一轮
#22: step2 过滤空规则片段,避免污染下游

Co-Authored-By: Claude Opus 4.7 <noreply@anthropic.com>
This commit is contained in:
2026-05-31 20:20:54 +08:00
parent 24dc6ff00c
commit 62266dde4d
3 changed files with 49 additions and 2 deletions
@@ -535,6 +535,20 @@ def _quick_validate(
return passed, gaps
def _build_coverage_feedback(gaps: dict) -> str:
"""Generate feedback text for re-prompting when coverage is below threshold."""
lines = []
for item in gaps.get("missing_paths", []):
lines.append(f"- {item}")
if lines:
return (
"\n## 覆盖反馈(上一次运行未满足覆盖要求,请重新生成并修复以下缺口)\n\n"
+ "\n".join(lines)
+ "\n\n请重新审视文档,为缺失的章节和表格行创建对应的 function_unit。"
)
return ""
def _collect_logic_tree_nodes(doc: dict) -> dict[str, dict[str, str]]:
"""Return {image_id: {node_id: node_type}} for all logic trees."""
result = {}
@@ -750,6 +764,29 @@ def run_ensemble_semantic_index(doc: dict) -> dict:
if v:
print(f" {k}: {len(v)} 个问题")
# Feedback retry: re-run with coverage feedback (one retry)
feedback = _build_coverage_feedback(gaps)
if feedback:
print(f"\n 覆盖反馈重试...")
try:
retry_prompt = build_prompt(doc, feedback, all_paths)
retry_result = call_llm(retry_prompt, max_retries=1, temperature=0.0)
n_retry_units = len(retry_result.get("function_units", []))
print(f" 重试返回: {n_retry_units} 功能单元")
if n_retry_units > 0:
# Merge retry into results and re-validate
semantic_indices.append(retry_result)
merged = ensemble_merge(semantic_indices)
merged["ensemble_temperatures"] = list(temperatures) + ["feedback_retry"]
passed, gaps = _quick_validate(merged, doc, all_paths)
merged["validation_passed"] = passed
merged["validation_gaps"] = {
k: v for k, v in gaps.items() if v
}
print(f" 重试后验证: {'PASS' if passed else 'GAPS FOUND'}")
except Exception as e:
print(f" 覆盖反馈重试失败: {e}")
return merged