src/snek/app.py

@@ -81,12 +81,10 @@ class Application(BaseApplication):
     async def task_runner(self):
         while True:
             task = await self.tasks.get() 
-            self.db.begin()
             try:
                 await task
             except Exception as ex:
                 print(ex)
-            self.db.commit()
 
     async def prepare_database(self,app):
         self.db.query("PRAGMA journal_mode=WAL")

src/snek/view/rpc.py

@@ -203,7 +203,9 @@ class RPCView(BaseView):
             if msg.type == web.WSMsgType.TEXT:
                 try:
                     async with Profiler():
+                        self.app.db.begin()
                         await rpc(msg.json())
+                        self.app.db.commit()
                 except Exception as ex:
                     print(ex, flush=True)
                     await self.services.socket.delete(ws)