diff --git a/src/snek/service/notification.py b/src/snek/service/notification.py
index 0b54a23..1392044 100644
--- a/src/snek/service/notification.py
+++ b/src/snek/service/notification.py
@@ -30,6 +30,7 @@ class NotificationService(BaseService):
             uid=channel_message_uid
         )
         user = await self.services.user.get(uid=channel_message["user_uid"])
+        self.app.db.begin()
         async for channel_member in self.services.channel_member.find(
             channel_uid=channel_message["channel_uid"],
             is_banned=False,
@@ -56,3 +57,5 @@ class NotificationService(BaseService):
                 await self.save(model)
             except Exception as ex:
                 raise Exception(f"Failed to create notification: {model.errors}.")
+
+        self.app.db.commit()