ZO-4267: bulk delete for postgresql connector if collection is deleted

ZeitOnline · Mar 1, 2024 · b842483 · b842483
1 parent 3bd86b4
commit b842483
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/core/src/zeit/connector/postgresql.py b/core/src/zeit/connector/postgresql.py
@@ -271,8 +271,8 @@ def __delitem__(self, uniqueid):
                     log.info('Ignored NotFound while deleting GCS blob %s', uniqueid)
         if props.is_collection:
             (parent, _) = self._pathkey(uniqueid)
-            paths = self.session.query(Path).filter(Path.parent_path.startswith(parent)).all()
-            for path in paths:
+            query = select(Path).where(Path.parent_path.startswith(parent))
+            for path in self.session.execute(query).scalars():
                 self.session.delete(path)
 
         self.session.delete(props)