select for update is one approach [with_for_update]

hjwp · hjwp · commit 4408a733357c · 2024-03-01T15:01:35.000Z
diff --git a/src/allocation/adapters/repository.py b/src/allocation/adapters/repository.py
@@ -20,5 +20,9 @@ def add(self, product):
         self.session.add(product)
 
     def get(self, sku):
-        print(sku, type(sku))
-        return self.session.query(model.Product).filter_by(sku=sku).first()
+        return (
+            self.session.query(model.Product)
+            .filter_by(sku=sku)
+            .with_for_update()
+            .first()
+        )
