diff --git a/app/services/letzshop/order_service.py b/app/services/letzshop/order_service.py index 2b98a294..11929600 100644 --- a/app/services/letzshop/order_service.py +++ b/app/services/letzshop/order_service.py @@ -711,6 +711,10 @@ class LetzshopOrderService: self.create_order(vendor_id, shipment) stats["imported"] += 1 except Exception as e: + # Rollback session to clear any partial changes from failed order + # This is crucial because create_letzshop_order may have flushed + # the order before the exception was raised (e.g., product not found) + self.db.rollback() stats["errors"] += 1 stats["error_messages"].append( f"Shipment {shipment_id}: {str(e)}"