perf(bundle_analysis): Batch delete bundles to avoid N+1 queries

apps/worker/services/bundle_analysis/report.py

@@ -211,11 +211,14 @@ def _attempt_init_from_previous_report(
             # if caching is on then update bundle.is_cached property to true
             # if caching is off then delete that bundle from the report
             update_fields = {}
+            bundles_to_delete = []
             for bundle in bundle_report.bundle_reports():
                 if bundle.name in bundles_to_be_cached:
                     update_fields[bundle.name] = True
                 else:
-                    bundle_report.delete_bundle_by_name(bundle.name)
+                    bundles_to_delete.append(bundle.name)
+            if bundles_to_delete:
+                bundle_report.delete_bundles_by_names(bundles_to_delete)
             if update_fields:
                 bundle_report.update_is_cached(update_fields)
             return bundle_report

libs/shared/shared/bundle_analysis/report.py

@@ -632,3 +632,47 @@ def delete_bundle_by_name(self, bundle_name: str) -> None:
             session.delete(bundle_to_be_deleted)
 
             session.commit()
+
+    @sentry_sdk.trace
+    def delete_bundles_by_names(self, bundle_names: list[str]) -> None:
+        """Batch delete multiple bundles by name in a single database session,
+        avoiding N+1 queries when deleting many bundles at once."""
+        if not bundle_names:
+            return
+        with get_db_session(self.db_path) as session:
+            bundles_to_delete = (
+                session.query(Bundle)
+                .filter(Bundle.name.in_(bundle_names))
+                .all()
+            )
+            if not bundles_to_delete:
+                return
+
+            bundle_ids = [b.id for b in bundles_to_delete]
+
+            sessions_to_delete = (
+                session.query(Session)
+                .filter(Session.bundle_id.in_(bundle_ids))
+                .all()
+            )
+            session_ids = [s.id for s in sessions_to_delete]
+
+            if len(sessions_to_delete) != len(bundles_to_delete):
+                raise Exception(
+                    "Data integrity error - cannot have Bundles without Sessions"
+                )
+
+            # Deletes Asset, Chunk, Module for all matching sessions at once
+            for model in [Asset, Chunk, Module]:
+                stmt = model.__table__.delete().where(
+                    model.session_id.in_(session_ids)
+                )
+                session.execute(stmt)
+
+            # Deletes Sessions and Bundles
+            for session_to_delete in sessions_to_delete:
+                session.delete(session_to_delete)
+            for bundle_to_delete in bundles_to_delete:
+                session.delete(bundle_to_delete)
+
+            session.commit()