GDPR model release gate and golden set evaluation for enterprise AI — Reference Architecture
Enterprise implementation parameters
Every value below is a parameter you can hold a vendor or an internal team to. Adjectives are not acceptance criteria.
| Deployment vector | Customer-managed VPC, provider model endpoint pinned to region |
|---|---|
| Security standard | GDPR |
| Applicable regimes | SOC 2 Type II, ISO/IEC 27001:2022, GDPR |
| Latency SLA | p95 ≤ 600ms — interactive surfaces need sub-second; batch jobs do not |
| Integration protocol | REST over HTTPS — the widest compatibility and the easiest audit story |
| Idempotency control | an Idempotency-Key header, honoured for 24h |
| Throughput envelope | ~2k rps per gateway node before connection churn dominates |
| Middleware requirement | policy decision point in front of the model gateway |
| Data classes in scope | PII, commercial-in-confidence data |
| Retention obligation | per the data class retention schedule, enforced automatically |
| Data residency | contracted processing region, asserted on every response |
| Contractual instrument | DPA plus a disclosed subprocessor list |
| Systems of record | SAP, Salesforce, Workday |
| Primary failure mode | a retried POST creating a duplicate record |
The control that resolves this is a Frozen Golden Set Release Gate, evaluated before the request reaches a model provider rather than audited afterwards. In regulated enterprise the binding constraint is GDPR, and the question it actually asks is what is the lawful basis, and can you actually erase. The shape below holds p95 ≤ 600ms over REST over HTTPS, and ships with a standard-library implementation that runs as written.
Where the rollout actually stalls
A model upgrade is approved on a demo and an aggregate score. Nobody can say which cases got worse, because the comparison is a single number against a test set that changes whenever it is inconvenient.
What GDPR specifically requires
GDPR asks two things an audit log does not answer: under what lawful basis was this processed, and can you erase it on request. Erasure is the harder one — a prompt embedded into a vector index and a fine-tune has propagated beyond the row you deleted.
The artifact that satisfies it is a lineage graph from source record to every derived artifact. The way teams most often fail it: an erasure request that cannot be honoured because the data survives in embeddings, caches and eval sets.
Implementation artifact — Per-slice release gate over a frozen golden set
Standard-library Python, no external dependencies, runs as written. Executed by the publish gate: if it raises, this page does not ship. Wire it behind REST over HTTPS; the failure mode it guards against is a retried POST creating a duplicate record. The output you hand the assessor is the data-subject lineage and erasure report.
"""Release gate on a frozen golden set, with per-slice thresholds.
The failure this prevents: a candidate model improves the aggregate score and
regresses badly on one slice that happens to matter. Aggregates hide that
(Simpson's paradox is not a curiosity here, it is the default outcome), so the
gate evaluates per slice and refuses on any slice regression beyond tolerance
even when the headline number improves.
"""
from dataclasses import dataclass, field
@dataclass(frozen=True)
class Case:
case_id: str
slice_name: str
prompt: str
expected: str
@dataclass
class GoldenSet:
"""Frozen on purpose. A golden set edited to make a release pass is not a
golden set, so mutation after freeze raises rather than warns."""
name: str
cases: list = field(default_factory=list)
_frozen: bool = False
def add(self, case: Case) -> None:
if self._frozen:
raise RuntimeError(f"{self.name} is frozen; create a new version")
self.cases.append(case)
def freeze(self) -> "GoldenSet":
self._frozen = True
return self
def slices(self) -> set:
return {c.slice_name for c in self.cases}
def score(model, golden: GoldenSet) -> dict:
per_slice: dict[str, list] = {}
for case in golden.cases:
ok = model(case.prompt) == case.expected
per_slice.setdefault(case.slice_name, []).append(ok)
return {s: sum(v) / len(v) for s, v in per_slice.items()}
def aggregate(scores: dict, golden: GoldenSet) -> float:
weights = {s: sum(1 for c in golden.cases if c.slice_name == s)
for s in scores}
total = sum(weights.values())
return sum(scores[s] * weights[s] for s in scores) / total
class ReleaseGate:
def __init__(self, tolerance: float = 0.02, floors: dict | None = None):
self.tolerance = tolerance
self.floors = floors or {}
def decide(self, baseline: dict, candidate: dict, golden: GoldenSet) -> dict:
regressions, floor_breaks = [], []
for s in sorted(set(baseline) | set(candidate)):
b, c = baseline.get(s, 0.0), candidate.get(s, 0.0)
if b - c > self.tolerance:
regressions.append({"slice": s, "baseline": round(b, 3),
"candidate": round(c, 3),
"delta": round(c - b, 3)})
floor = self.floors.get(s)
if floor is not None and c < floor:
floor_breaks.append({"slice": s, "candidate": round(c, 3),
"floor": floor})
agg_b, agg_c = aggregate(baseline, golden), aggregate(candidate, golden)
return {
"aggregate_baseline": round(agg_b, 3),
"aggregate_candidate": round(agg_c, 3),
"aggregate_improved": agg_c > agg_b,
"slice_regressions": regressions,
"floor_breaches": floor_breaks,
"release": not regressions and not floor_breaks,
}
if __name__ == "__main__":
g = GoldenSet("claims-triage-v1")
for i in range(40):
g.add(Case(f"c{i}", "common", f"p{i}", f"a{i}"))
for i in range(10):
g.add(Case(f"r{i}", "rare_high_value", f"rp{i}", f"ra{i}"))
g.freeze()
baseline_answers = {c.prompt: c.expected for c in g.cases}
def baseline_model(p): return baseline_answers[p]
# Candidate: better on the big slice, broken on the small critical one.
def candidate_model(p):
if p.startswith("rp"):
return "wrong"
return baseline_answers[p]
base = score(baseline_model, g)
cand = score(candidate_model, g)
gate = ReleaseGate(tolerance=0.02, floors={"rare_high_value": 0.90})
decision = gate.decide(base, cand, g)
assert decision["aggregate_candidate"] >= 0.79, decision
assert not decision["release"], "a slice regression must block the release"
assert decision["slice_regressions"][0]["slice"] == "rare_high_value"
assert decision["floor_breaches"], decision
clean = gate.decide(base, base, g)
assert clean["release"], clean
try:
g.add(Case("x", "common", "p", "a"))
raise AssertionError("edited a frozen golden set")
except RuntimeError:
pass
print("Evaluation release gate: OK")
print(f" aggregate {decision['aggregate_baseline']} -> "
f"{decision['aggregate_candidate']}, release={decision['release']}, "
f"slice regressions {len(decision['slice_regressions'])}")
The GDPR control, as code
Article 17 erasure propagated into derived artifacts. This is the artifact an assessor asks for under GDPR specifically — it is not the same control as the one above, and a system that implements one does not thereby implement the other. It executes under the same publish gate.
"""Article 17 erasure that propagates into derived artifacts.
The erasure request everyone implements is a DELETE on the source row. The one
that fails an audit is the derived copy: embeddings in a vector index, a cached
retrieval chunk, a fine-tuning corpus, a prompt log. Article 17(2) expects
controllers to take reasonable steps to inform processors of the erasure, and a
vector built from personal data is still personal data.
So erasure is modelled as a lineage walk with a receipt per derived artifact,
and the request is not complete until every downstream store confirms.
"""
from datetime import datetime, timezone
class Store:
def __init__(self, name: str, kind: str):
self.name, self.kind = name, kind
self.rows: dict[str, dict] = {}
self.erased: list[str] = []
def put(self, key: str, subject_id: str, payload: str) -> None:
self.rows[key] = {"subject_id": subject_id, "payload": payload}
def erase_subject(self, subject_id: str) -> int:
doomed = [k for k, v in self.rows.items() if v["subject_id"] == subject_id]
for k in doomed:
del self.rows[k]
self.erased.append(k)
return len(doomed)
def holds(self, subject_id: str) -> int:
return sum(1 for v in self.rows.values() if v["subject_id"] == subject_id)
class ErasureOrchestrator:
"""Lineage-aware erasure. A store that is not registered cannot be erased,
so registration is the control — an unregistered derived store is exactly
how personal data survives a 'completed' erasure."""
def __init__(self):
self.stores: list[Store] = []
self.lineage: dict[str, list[str]] = {}
def register(self, store: Store, derived_from: str | None = None) -> Store:
self.stores.append(store)
if derived_from:
self.lineage.setdefault(derived_from, []).append(store.name)
return store
def execute(self, subject_id: str) -> dict:
receipts = []
for store in self.stores:
held = store.holds(subject_id)
removed = store.erase_subject(subject_id)
receipts.append({"store": store.name, "kind": store.kind,
"held": held, "erased": removed})
residual = {s.name: s.holds(subject_id) for s in self.stores
if s.holds(subject_id)}
return {
"subject_id": subject_id,
"completed_at": datetime.now(timezone.utc).isoformat(timespec="seconds"),
"receipts": receipts,
"residual": residual,
"complete": not residual,
"derived_stores_covered": sorted(
s.name for s in self.stores if s.kind != "source"),
}
if __name__ == "__main__":
orch = ErasureOrchestrator()
src = orch.register(Store("crm_postgres", "source"))
vec = orch.register(Store("vector_index", "embedding"), derived_from="crm_postgres")
cache = orch.register(Store("retrieval_cache", "cache"), derived_from="vector_index")
logs = orch.register(Store("prompt_log", "log"), derived_from="crm_postgres")
src.put("c-1", "subject-77", "Jana Soor, contract renewal notes")
vec.put("v-1", "subject-77", "[0.11, -0.4, ...]")
cache.put("k-1", "subject-77", "chunk: contract renewal notes")
logs.put("l-1", "subject-77", "prompt containing the same notes")
src.put("c-2", "subject-90", "unrelated subject")
result = orch.execute("subject-77")
assert result["complete"], result["residual"]
assert len(result["derived_stores_covered"]) == 3, result
assert sum(r["erased"] for r in result["receipts"]) == 4, result
assert src.holds("subject-90") == 1, "erasure must not over-reach"
# An unregistered derived store is the failure this design exists to expose.
orphan = Store("analytics_extract", "warehouse")
orphan.put("a-1", "subject-77", "same personal data, different copy")
assert orphan.holds("subject-77") == 1
assert orphan.name not in {s.name for s in orch.stores}
print("GDPR Article 17 lineage erasure: OK")
print(f" stores erased {len(result['receipts'])}, complete={result['complete']}")
print(f" UNREGISTERED store still holding data: {orphan.name} "
f"({orphan.holds('subject-77')} row) — registration is the control")
Reference architecture
Frozen Golden Set Release Gate — the request path, with the decision points that must exist before the first model call:
flowchart LR
CAND[Candidate model] --> SC[Score per slice]
BASE[Baseline scores] --> CMP{Compare per slice}
SC --> CMP
CMP -->|slice regressed| BLOCK[Refuse release]
CMP -->|below floor| BLOCK
CMP -->|all slices hold| REL[Release + decision record]
BLOCK --> REC[Record which slice and by how much]Implementation components
- Frozen golden set — Versioned and immutable; editing it after freeze raises.
- Slice taxonomy — Rare-but-critical cases are their own slice, not noise in the mean.
- Per-slice thresholds — Tolerance for regression plus an absolute floor per slice.
- Deterministic scorer — Same inputs, same score — a flaky scorer makes the gate decorative.
- Release gate — Refuses on any slice regression even when the aggregate improves.
- Decision record — What was compared, which slices moved, who accepted the risk.
Controls and acceptance parameters
Each row carries an acceptance parameter rather than an adjective, because "low latency" cannot be signed off. Retention here is bound by per the data class retention schedule, enforced automatically.
| Category | Risk | Control | Acceptance parameter |
|---|---|---|---|
| GDPR | Erasure request cannot reach data derived into embeddings or caches | Tag every derived artifact with the source record id; make erasure a graph traversal, not a row delete | Erasure completes across all derived stores within 30 days, evidenced by a lineage report per request |
| Operational | Aggregate improves while a critical slice regresses | Per-slice comparison with an absolute floor on named slices | No release where any slice falls more than the tolerance; tested |
| Operational | Golden set edited to make a failing release pass | Freeze on publish; mutation raises and a new version is required | Set version recorded on every decision; edits after freeze impossible |
| Operational | Scorer is non-deterministic, so the gate is noise | Deterministic comparison; sampling seeded and recorded | Same candidate scores identically across repeated runs |
| Data privacy | Production data copied into the golden set | Golden cases are synthesised or consented; provenance recorded per case | 100% of cases carry a provenance tag; no raw production records |
| Cost control | Full evaluation on every commit is unaffordable | Tiered: smoke slice per commit, full set per release candidate | Full-set runs bounded per week; cost per run tracked |
| Latency SLA | Evaluation blocks the release pipeline for hours | Parallel slice execution with a hard wall-clock budget | Gate returns a decision within the agreed window or fails closed |
| Operational | A slice nobody defined is where the regression lands | Slice taxonomy reviewed when incidents reveal an unmodelled case | Every post-incident review either maps to a slice or adds one |
Questions to answer before approval
- A data subject requests erasure. Trace exactly what gets deleted, including embeddings and cached completions.
Every derived artifact carries the source record id, so erasure traverses the lineage graph. The completion report lists each store touched and the rows removed. - Which slices did the candidate model get worse on, and by how much?
The gate reports a per-slice delta for every slice, and the decision record keeps it. An aggregate alone cannot answer this, which is why it is not the gate. - What stops someone editing the evaluation set until the release passes?
The set is frozen on publish — mutation raises rather than warns, and a change requires a new version with its own identifier recorded on every subsequent decision. - If the aggregate score improves by two points, can the release still be refused?
Yes, and it must be. A slice regression beyond tolerance, or any breach of a named slice's floor, refuses the release regardless of the aggregate. - Where is the record of who accepted a known regression, and on what basis?
In the decision record attached to the release: the slices that moved, the magnitude, and the named person who accepted it. An unaccepted regression cannot ship. - How do you know the scorer gives the same answer twice?
The scorer is deterministic and any sampling is seeded, with the seed recorded. The same candidate against the same frozen set produces the same report.
Related reference architectures
- Part of enterprise ai compliance architecture.
- For the related constraint, see GDPR retrieval architecture with citation integrity for enterprise LLM.
- Where this interacts with another regime, see GDPR cost control architecture for enterprise LLM deployment.
- This pattern also governs GDPR reference architecture for enterprise LLM deployment at scale.
- A different failure mode of the same component: GDPR tracing and token accounting architecture for enterprise LLM.
- If this is the blocker in front of you: enterprise AI infrastructure review.
Enterprise infrastructure review
If you are carrying this blocker, the useful next step is not a demo. It is a review of your actual request path against the control points above:
- Which of the 6 components exist in your estate today, and which are assumed
- Your current numbers against the 7 acceptance parameters, starting with p95 ≤ 600ms
- Which GDPR control questions you cannot yet answer, and what closes each gap