Compare commits
10 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 440cd5812b | |||
| 55dcfc1b3e | |||
| 4a8032665f | |||
| 6536c7fa9d | |||
| 2cd02453ec | |||
| 140e49342c | |||
| 93bbfe6029 | |||
| 6b1424b1c4 | |||
| efb5ed481e | |||
| e54a221f34 |
@@ -86,7 +86,8 @@ COVERAGE_TARGET = float(os.environ.get("IR_COVERAGE_TARGET", "0.95"))
|
||||
ENSEMBLE_TEMPERATURES = [
|
||||
float(os.environ.get("IR_ENSEMBLE_T1", "0.0")),
|
||||
float(os.environ.get("IR_ENSEMBLE_T2", "0.3")),
|
||||
float(os.environ.get("IR_ENSEMBLE_T3", "0.7")),
|
||||
float(os.environ.get("IR_ENSEMBLE_T3", "0.5")),
|
||||
float(os.environ.get("IR_ENSEMBLE_T4", "0.7")),
|
||||
]
|
||||
|
||||
|
||||
|
||||
@@ -186,6 +186,8 @@
|
||||
|
||||
8. **开关关闭状态**:开关关闭时所有限制失效,这也必须作为一条规则输出(path: ["...", "开关关闭", "无限制"])。
|
||||
|
||||
9. **功能完整性要求(重要)**:上下文包中的每个表格行、每条文字描述、每个逻辑树路径都必须被至少一条规则覆盖。仔细检查上下文包,确保不遗漏任何数据来源。如果上下文包中有表格,每条表格行至少生成一条对应规则。
|
||||
|
||||
{format_feedback}
|
||||
|
||||
## 输出格式
|
||||
|
||||
@@ -880,9 +880,9 @@ def run_ensemble_semantic_index(doc: dict) -> dict:
|
||||
if v:
|
||||
print(f" {k}: {len(v)} 个问题")
|
||||
|
||||
# Feedback retry: re-run with coverage feedback (up to 2 retries, quality-gated)
|
||||
# Feedback retry: re-run with coverage feedback (up to 3 retries, quality-gated)
|
||||
retry_count = 0
|
||||
while retry_count < 2:
|
||||
while retry_count < 3:
|
||||
feedback = _build_coverage_feedback(gaps)
|
||||
if not feedback:
|
||||
break
|
||||
@@ -906,13 +906,16 @@ def run_ensemble_semantic_index(doc: dict) -> dict:
|
||||
if src.get("section"):
|
||||
retry_sections.add(src["section"])
|
||||
print(f" 重试新增 sections: {sorted(retry_sections)}", flush=True)
|
||||
# Quality gate: only include retry if it improves coverage
|
||||
# Quality gate: include retry if it adds new sections or doesn't regress coverage
|
||||
trial_indices = semantic_indices + [retry_result]
|
||||
trial_merged = ensemble_merge(trial_indices)
|
||||
trial_passed, trial_gaps = _quick_validate(trial_merged, doc, all_paths)
|
||||
trial_warnings = len(trial_gaps.get("coverage_warnings", []))
|
||||
trial_missing = len(trial_gaps.get("missing_table_rows", []))
|
||||
if trial_warnings < pre_warnings or trial_missing < pre_missing_rows:
|
||||
improved = trial_warnings < pre_warnings or trial_missing < pre_missing_rows
|
||||
no_regression = trial_warnings <= pre_warnings and trial_missing <= pre_missing_rows
|
||||
has_new_sections = len(retry_sections) > 0
|
||||
if improved or (no_regression and has_new_sections):
|
||||
semantic_indices.append(retry_result)
|
||||
merged = trial_merged
|
||||
passed, gaps = trial_passed, trial_gaps
|
||||
|
||||
@@ -174,11 +174,25 @@ def _normalize_rule(rule: dict) -> dict:
|
||||
sources = rule.get("sources", [])
|
||||
valid_types = {"table", "text", "logic_tree"}
|
||||
|
||||
def _clean_section(val):
|
||||
"""Normalize section value: list→first element, ensure string."""
|
||||
if isinstance(val, list):
|
||||
return str(val[0]).strip() if val else ""
|
||||
if isinstance(val, str):
|
||||
return val.strip()
|
||||
return str(val).strip() if val else ""
|
||||
|
||||
# Normalize section fields that might be lists (LLM format instability)
|
||||
for s in sources:
|
||||
sec = s.get("section")
|
||||
if sec is not None:
|
||||
s["section"] = _clean_section(sec)
|
||||
|
||||
# try to infer a default section from the rule path
|
||||
default_section = ""
|
||||
for s in sources:
|
||||
sec = s.get("section", "")
|
||||
if sec and sec.strip():
|
||||
if sec and isinstance(sec, str) and sec.strip():
|
||||
default_section = sec.strip()
|
||||
break
|
||||
if not default_section:
|
||||
@@ -192,7 +206,12 @@ def _normalize_rule(rule: dict) -> dict:
|
||||
if stype and stype not in valid_types:
|
||||
src["type"] = "text"
|
||||
stype = "text"
|
||||
if stype in ("table", "text"):
|
||||
if stype == "table":
|
||||
if not src.get("section"):
|
||||
src["section"] = default_section
|
||||
if src.get("row") is None:
|
||||
src["row"] = 0
|
||||
elif stype == "text":
|
||||
if not src.get("section"):
|
||||
src["section"] = default_section
|
||||
else:
|
||||
|
||||
@@ -512,6 +512,18 @@ class TestNormalizeRule:
|
||||
normalized = _normalize_rule(rule)
|
||||
assert "section" not in normalized["sources"][0]
|
||||
|
||||
|
||||
def test_normalize_table_source_null_row(self):
|
||||
"""Table source with null row gets row=0 (defensive)."""
|
||||
rule = {
|
||||
"trigger": {"conditions": [{"signal": "x", "operator": "==", "value": "1"}]},
|
||||
"sources": [
|
||||
{"type": "table", "section": "3.1 功能", "row": None},
|
||||
],
|
||||
}
|
||||
normalized = _normalize_rule(rule)
|
||||
assert normalized["sources"][0]["row"] == 0
|
||||
|
||||
def test_normalize_source_invalid_type(self):
|
||||
"""Invalid source types (LLM hallucinations) are normalized to text."""
|
||||
rule = {
|
||||
@@ -538,3 +550,28 @@ class TestNormalizeRule:
|
||||
assert len(normalized["sources"]) == 1
|
||||
assert normalized["sources"][0]["type"] == "text"
|
||||
assert normalized["sources"][0]["section"] == "3.1 策略"
|
||||
|
||||
def test_normalize_section_is_list(self):
|
||||
"""Section field that is a list (LLM format bug) is normalized to string."""
|
||||
rule = {
|
||||
"trigger": {"conditions": [{"signal": "x", "operator": "==", "value": "1"}]},
|
||||
"sources": [
|
||||
{"type": "table", "section": ["状态", "系统设置"], "row": 1},
|
||||
{"type": "text", "section": ["后台限制"], "text_snippet": "x"},
|
||||
],
|
||||
}
|
||||
normalized = _normalize_rule(rule)
|
||||
assert normalized["sources"][0]["section"] == "状态"
|
||||
assert normalized["sources"][1]["section"] == "后台限制"
|
||||
|
||||
def test_normalize_section_is_empty_list(self):
|
||||
"""Empty list section falls back to rule path."""
|
||||
rule = {
|
||||
"trigger": {"conditions": [{"signal": "x", "operator": "==", "value": "1"}]},
|
||||
"path": "4.2 关闭流程 > decision",
|
||||
"sources": [
|
||||
{"type": "table", "section": [], "row": 1},
|
||||
],
|
||||
}
|
||||
normalized = _normalize_rule(rule)
|
||||
assert normalized["sources"][0]["section"] == "4.2 关闭流程"
|
||||
|
||||
@@ -83,8 +83,8 @@ def test_output_dir_structure():
|
||||
|
||||
|
||||
def test_ensemble_temperatures_count():
|
||||
"""Should have exactly 3 ensemble temperatures."""
|
||||
assert len(config.ENSEMBLE_TEMPERATURES) == 3
|
||||
"""Should have exactly 4 ensemble temperatures."""
|
||||
assert len(config.ENSEMBLE_TEMPERATURES) == 4
|
||||
|
||||
|
||||
def test_max_tokens_is_int():
|
||||
|
||||
Reference in New Issue
Block a user