modify uow to pass self to messagebus [uow_passes_self_to_messagebus]

hjwp · hjwp · commit 2910812d0b8e · 2019-11-20T21:12:36.000Z
diff --git a/src/allocation/unit_of_work.py b/src/allocation/unit_of_work.py
@@ -26,7 +26,7 @@ def publish_events(self):
         for product in self.products.seen:
             while product.events:
                 event = product.events.pop(0)
-                messagebus.handle(event)
+                messagebus.handle(event, uow=self)
 
     @abc.abstractmethod
     def _commit(self):
