732642856
73 lines
2.9 KiB
Python
73 lines
2.9 KiB
Python
#!/usr/bin/env python3
|
|
"""Create actionable closure tickets for three-engine mismatch rows."""
|
|
from __future__ import annotations
|
|
|
|
import argparse
|
|
import json
|
|
from collections import Counter
|
|
from pathlib import Path
|
|
from typing import Any
|
|
|
|
|
|
POLICY = {
|
|
"endpoint_or_varga_semantics": ("P0", "endpoint_contract", "identified endpoint/method contract with ayanamsa, node mode, varga, timezone semantics"),
|
|
"shadbala_formula_variant": ("P0", "formula_source", "public formula source + unit/cap/floor evidence for the component"),
|
|
"derived_total_from_component_variants": ("P1", "unit_schema", "component closure before total recomputation; explicit Rupa/Virupa total rule"),
|
|
"ashtakavarga_table_or_contributor_variant": ("P1", "worked_example", "public worked BAV/SAV table with contributor set, shodhana state, and Lagna inclusion"),
|
|
}
|
|
|
|
|
|
def build_queue(arbitration_path: str | Path) -> dict[str, Any]:
|
|
path = Path(arbitration_path)
|
|
report = json.loads(path.read_text(encoding="utf-8"))
|
|
tickets = []
|
|
for index, row in enumerate(report.get("rows") or [], start=1):
|
|
priority, owner_track, required = POLICY.get(
|
|
row["category"],
|
|
("P2", "worked_example", "manual source review and worked example required"),
|
|
)
|
|
tickets.append({
|
|
"ticket_id": f"TEMCQ-{index:03d}",
|
|
"priority": priority,
|
|
"owner_track": owner_track,
|
|
"section": row.get("section"),
|
|
"field": row.get("field"),
|
|
"category": row.get("category"),
|
|
"differing_engines": row.get("differing_engines") or [],
|
|
"required_evidence": required,
|
|
"closure_status": "open",
|
|
"commercial_visibility": "do_not_expose_raw",
|
|
})
|
|
return {
|
|
"scope": "three_engine_mismatch_closure_queue",
|
|
"source_arbitration": str(path),
|
|
"status": "open" if tickets else "empty",
|
|
"truth_policy": "no_majority_vote",
|
|
"production_tuning_allowed": False,
|
|
"summary": {
|
|
"source_mismatch_count": report.get("mismatch_count", 0),
|
|
"queue_count": len(tickets),
|
|
"priority_counts": dict(Counter(ticket["priority"] for ticket in tickets)),
|
|
"owner_track_counts": dict(Counter(ticket["owner_track"] for ticket in tickets)),
|
|
},
|
|
"queue": tickets,
|
|
}
|
|
|
|
|
|
def main() -> int:
|
|
parser = argparse.ArgumentParser(description=__doc__)
|
|
parser.add_argument("arbitration", nargs="?", default="references/oracle/three_engine_mismatch_arbitration_2026_07_19.json")
|
|
parser.add_argument("--output", type=Path)
|
|
args = parser.parse_args()
|
|
queue = build_queue(args.arbitration)
|
|
text = json.dumps(queue, ensure_ascii=False, indent=2, sort_keys=True) + "\n"
|
|
if args.output:
|
|
args.output.parent.mkdir(parents=True, exist_ok=True)
|
|
args.output.write_text(text, encoding="utf-8")
|
|
print(text, end="")
|
|
return 0
|
|
|
|
|
|
if __name__ == "__main__":
|
|
raise SystemExit(main())
|