Transactions.

Browse Source
This commit is contained in:
retoor 2025-03-27 21:01:17 +01:00
parent 9d5815ed10
commit 8810679fd8
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/snek/app.py
View File

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