select for update is one approach [with_for_update]

hjwp · hjwp · commit 6e18fd11475a · 2020-01-08T20:41:48.000Z
diff --git a/src/allocation/adapters/repository.py b/src/allocation/adapters/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()
