diff --git a/backend-compliance/compliance/services/control_generator.py b/backend-compliance/compliance/services/control_generator.py
index 2b43ae8..43dbdb0 100644
--- a/backend-compliance/compliance/services/control_generator.py
+++ b/backend-compliance/compliance/services/control_generator.py
@@ -1391,6 +1391,12 @@ Gib ein JSON-Array zurueck mit GENAU {len(chunks)} Objekten. Jedes Objekt hat di
         loaded = sum(1 for emb in embeddings if emb)
         logger.info("Pre-loaded %d/%d embeddings", loaded, len(texts))
 
+        # Reset DB session after long-running embedding operation to avoid stale connections
+        try:
+            self.db.rollback()
+        except Exception:
+            pass
+
     def _load_existing_controls(self) -> list[dict]:
         """Load existing controls from DB (cached per pipeline run)."""
         if self._existing_controls is not None: