fix(tcf): per-vendor commit damit ein Fail die naechsten Inserts nicht blockt

2026-05-22 07:54:22 +02:00
parent 19d4b12e07
commit 6c35bcf116
1 changed files with 3 additions and 2 deletions
@@ -118,12 +118,13 @@ async def fetch_and_ingest_tcf_vendors(db: Session) -> dict:
                "v": f"[TCF-{vid}] {name}",
                "pu": privacy_url, "cat": category,
                "purp": f"IAB TCF v2 Purposes: {sorted(all_purposes)}"})
+            db.commit()  # Per-Vendor-Commit damit ein Fehler nicht
+                         # die naechsten Eintraege blockt.
            inserted += 1
        except Exception as e:
            logger.warning("TCF vendor %s insert failed: %s", vid, e)
            skipped += 1
-            db.rollback()  # neue Transaktion fuer naechsten Insert
-    db.commit()
+            db.rollback()  # frische Transaktion fuer den naechsten Insert
    return {"n_vendors_in_gvl": len(vendors), "inserted": inserted,
            "skipped": skipped}