Uow no longer puts events directly on the bus [uow_collect_new_events]

hjwp · hjwp · commit a8ec47f48487 · 2024-03-01T15:05:12.000Z
diff --git a/src/allocation/service_layer/unit_of_work.py b/src/allocation/service_layer/unit_of_work.py
@@ -8,7 +8,6 @@
 
 from allocation import config
 from allocation.adapters import repository
-from . import messagebus
 
 
 class AbstractUnitOfWork(abc.ABC):
@@ -22,13 +21,11 @@ def __exit__(self, *args):
 
     def commit(self):
         self._commit()
-        self.publish_events()
 
-    def publish_events(self):
+    def collect_new_events(self):
         for product in self.products.seen:
             while product.events:
-                event = product.events.pop(0)
-                messagebus.handle(event)
+                yield product.events.pop(0)
 
     @abc.abstractmethod
     def _commit(self):
