Transactions.

src/snek/service/chat.py

@@ -20,11 +20,11 @@ class ChatService(BaseService):
         
         
         user = await self.services.user.get(uid=user_uid)
-        await self.services.notification.create_channel_message(channel_message_uid)
+        async self.app.create_task(self.services.notification.create_channel_message(channel_message_uid))
         channel['last_message_on'] = now()
         await self.services.channel.save(channel)
         
-        await self.app.create_task(self.services.socket.broadcast(channel_uid, dict(
+        self.services.socket.broadcast(channel_uid, dict(
             message=channel_message["message"],
             html=channel_message["html"],
             user_uid=user_uid,
@@ -35,5 +35,5 @@ class ChatService(BaseService):
             username=user['username'],
             uid=channel_message['uid'],
             user_nick=user['nick']
-        )))
+        ))
         return True