marcopanandClaude Opus 4.8
c4d130828f
Implementazione del piano di remediation progressiva sui difetti emersi dall'analisi dell'harness. Tutto verificato: 214 test Python (incl. L0 su Postgres reale), 14 test JS del gate, ruff pulito. Blocco 1 (CRITICA, integrazione gate↔CLI): - phase advance: gate usa --auto + exit 6; reviewer_confirm kind:phase fa advance esplicito che applica i prerequisiti (prima non avanzava per le fasi a conferma umana). - cte plan riceve i --name dal gate (param names); set-question con id posizionale; skill `tht search find`; nuovo comando `tht memory save-one` con dedup hash client-side in save_one_memory. Blocco 2 (D15, stato post-rollback): - campo `phase` su DecisionRecord + effective_decisions phase-aware per i subject "a nome" (cte_approved ecc.); _compute_promotions e finalize sulla vista effective; finalize confronta col piano CTE effettivo, non glob; `decision add --retracts` + comando `decision retract`. Blocco 3 (D7 read-only + D6 manifest): - assert_read_only su tutti e quattro i codepath (direct + REST); - manifest author/summary/updated_at/updated_by/schema_version popolati + helper touch_manifest sulle mutazioni. Blocco 4-5 (D14a/D14b): - decision_min_phase data-driven via `emits:` in workflow.yaml; - formula evidence: status auto, search_formulas, gruppo CLI `tht formula`, `search find --kind formula`, load_evidence_dir salta i .sql.md. Blocco 6 (robustezza): - taskdoc slice promoted_tables + bound enforced; report escaping/bound + rsplit note; filtro kind reader REST/direct; conteggio upserted robusto; guard REST run_query non-list; LSH disallineato -> LshIndexError. Blocco 7 (pulizia): - dead code gate e KIND_TO_TABLE morto rimossi; doc Postgres-only (README + connection.py). Blocco 0 (parziale): test di compatibilità firma gate↔CLI (tests/integration). Rinviati: fake-Pi runtime completo, artifact-gate da disco (#23), parità eligibility REST/direct (#28), unificazione reserved-labels (#30), memory_rejected da deselezione (#33). Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>
107 lines
3.6 KiB
Python
107 lines
3.6 KiB
Python
from datetime import UTC, datetime
|
|
from pathlib import Path
|
|
from typing import Literal
|
|
|
|
from pydantic import BaseModel
|
|
|
|
DECISIONS_FILE = "review_decisions.jsonl"
|
|
|
|
# 22 tipi di the reference implementation (verified leggendo session/decisions.py) + 1 nuovo (D15):
|
|
# `decision_retracted` per il rollback a granularità step (ritira una decisione
|
|
# senza cancellarne la riga dal log di audit; effective_decisions la onora).
|
|
DecisionType = Literal[
|
|
"concept_clarified",
|
|
"question_rewritten",
|
|
"table_promoted",
|
|
"table_excluded",
|
|
"column_corrected",
|
|
"join_modified",
|
|
"evidence_accepted",
|
|
"evidence_rejected",
|
|
"ambiguity_open",
|
|
"memory_rejected",
|
|
"cte_approved",
|
|
"cte_corrected",
|
|
"cte_rejected",
|
|
"sql_revised",
|
|
"sql_approved",
|
|
"sql_rejected",
|
|
"phase_approved",
|
|
"phase_auto_approved",
|
|
"phase_reopened",
|
|
"phase_skipped",
|
|
"datamart_requested",
|
|
"datamart_declined",
|
|
# D15: marker di ritrazione. subject = "phase:N", retracts = decision_seq ritirata.
|
|
# Resta nel log di audit (append-only); effective_decisions() la esclude dalla vista.
|
|
"decision_retracted",
|
|
# D14a: valore citato nella domanda ancorato a una o piu' colonne. subject =
|
|
# "phase:4", detail = il valore (es. "ablazione"), rationale = la/e colonna/e scelta/e
|
|
# dal reviewer (aggregate_lsh_multi le espone tutte senza collassare al miglior match).
|
|
"value_grounded",
|
|
# D14b: formula di concetto approvata/rifiutata dal reviewer. subject = "phase:4",
|
|
# detail = il concetto (es. "fascia pediatrica"), rationale = la/e colonna/e o il motivo.
|
|
# retrieve_formula restituisce i candidati; queste decisioni registrano la scelta.
|
|
"concept_formula_approved",
|
|
"concept_formula_rejected",
|
|
]
|
|
|
|
|
|
class DecisionRecord(BaseModel):
|
|
seq: int
|
|
ts: datetime
|
|
type: DecisionType
|
|
subject: str
|
|
detail: str = ""
|
|
rationale: str = ""
|
|
# D15: se type == "decision_retracted", indica quale seq viene ritirata.
|
|
retracts: int | None = None
|
|
# D15: la fase corrente al momento della scrittura (high-water-mark). Permette a
|
|
# effective_decisions() di marcare stale le decisioni il cui subject NON e' "phase:N"
|
|
# (es. cte_approved usa il nome del CTE) dopo un rollback. None per record storici
|
|
# (pre-fix) o costruiti a mano: in quel caso si ricade sulla logica basata sul subject.
|
|
phase: int | None = None
|
|
|
|
|
|
def list_decisions(session_dir: Path) -> list[DecisionRecord]:
|
|
path = session_dir / DECISIONS_FILE
|
|
if not path.exists():
|
|
return []
|
|
return [
|
|
DecisionRecord.model_validate_json(line)
|
|
for line in path.read_text().splitlines()
|
|
if line.strip()
|
|
]
|
|
|
|
|
|
def append_decision(
|
|
session_dir: Path,
|
|
*,
|
|
type: str,
|
|
subject: str,
|
|
detail: str = "",
|
|
rationale: str = "",
|
|
retracts: int | None = None,
|
|
) -> DecisionRecord:
|
|
# Fase corrente PRIMA dell'append (high-water-mark D15). Import lazy: phase.py
|
|
# importa decisions.py (ciclo). Per i marker di fase (subject "phase:N") il valore
|
|
# e' ridondante col subject; per le decisioni sostanziali con subject "a nome"
|
|
# (cte_approved, ...) e' l'unico modo per filtrarle dopo un reopen.
|
|
from tht.phase import current_phase
|
|
|
|
record = DecisionRecord(
|
|
seq=len(list_decisions(session_dir)) + 1,
|
|
ts=datetime.now(UTC),
|
|
type=type,
|
|
subject=subject,
|
|
detail=detail,
|
|
rationale=rationale,
|
|
retracts=retracts,
|
|
phase=current_phase(session_dir),
|
|
)
|
|
path = session_dir / DECISIONS_FILE
|
|
path.parent.mkdir(parents=True, exist_ok=True)
|
|
with path.open("a") as f:
|
|
f.write(record.model_dump_json() + "\n")
|
|
return record
|