diff --git a/control-pipeline/services/batch_dedup_runner.py b/control-pipeline/services/batch_dedup_runner.py index 715cf27..e305e2a 100644 --- a/control-pipeline/services/batch_dedup_runner.py +++ b/control-pipeline/services/batch_dedup_runner.py @@ -606,9 +606,9 @@ class BatchDedupRunner: }) self.db.commit() except Exception as e: - logger.error("BatchDedup _write_review error: %s", e) + logger.warning("BatchDedup _write_review skipped (FK or other error): %s", e) self.db.rollback() - raise + self.stats["errors"] += 1 # ── Progress ─────────────────────────────────────────────────────────