backend/app/services/scrapers/domrf_catalog_object.py

@@ -449,6 +449,15 @@ async def scrape_catalog_objects(
             else:
                 stats["failed"] += 1
 
+    # Commit outer transaction: SAVEPOINT (`begin_nested`) releases внутри loop,
+    # но outer tx остаётся autobegin'd — без commit() все UPDATE'ы откатятся
+    # при db.close() в Celery task.
+    try:
+        db.commit()
+    except Exception:
+        db.rollback()
+        raise
+
     logger.info(
         "scrape_catalog_objects done: processed=%d succeeded=%d failed=%d skipped=%d",
         stats["processed"],