Merge pull request 'fix(22d): commit outer transaction in scrape_catalog_objects orchestrator' (#342) from fix/22d-catalog-objects-missing-commit into main
All checks were successful
Deploy / changes (push) Successful in 5s
Deploy / build-frontend (push) Has been skipped
Deploy / build-backend (push) Successful in 1m21s
Deploy / build-worker (push) Successful in 2m25s
Deploy / deploy (push) Successful in 52s

This commit is contained in:
lekss361 2026-05-17 22:13:49 +00:00
commit 05b6966a5f

View file

@ -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"],