select for update is one approach [with_for_update]

hjwp · hjwp · commit 79fe2dabc4d4 · 2019-11-20T21:10:51.000Z
diff --git a/src/allocation/repository.py b/src/allocation/repository.py
@@ -22,5 +22,7 @@ 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()
