alternative: isolation=SERIALIZABLE [chapter_06_aggregate_ends]

hjwp · hjwp · commit 6571c4d595ee · 2020-01-08T20:41:48.000Z
diff --git a/src/allocation/adapters/repository.py b/src/allocation/adapters/repository.py
@@ -22,7 +22,4 @@ def add(self, product):
         self.session.add(product)
 
     def get(self, sku):
-        return self.session.query(model.Product) \
-                           .filter_by(sku=sku) \
-                           .with_for_update() \
-                           .first()
+        return self.session.query(model.Product).filter_by(sku=sku).first()
diff --git a/src/allocation/service_layer/unit_of_work.py b/src/allocation/service_layer/unit_of_work.py
@@ -30,6 +30,7 @@ def rollback(self):
 
 DEFAULT_SESSION_FACTORY = sessionmaker(bind=create_engine(
     config.get_postgres_uri(),
+    isolation_level="SERIALIZABLE",
 ))
 
 class SqlAlchemyUnitOfWork(AbstractUnitOfWork):
