Transactions.

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

5
src/snek/app.py
View File

@ -2,6 +2,7 @@ import pathlib
import asyncio import asyncio
import logging import logging
import time
from snek.view.threads import ThreadsView from snek.view.threads import ThreadsView
@ -83,7 +84,11 @@ class Application(BaseApplication):
task = await self.tasks.get() task = await self.tasks.get()
self.db.begin() self.db.begin()
try: try:
task_start = time.time()
await task await task
task_end = time.time()
print(f"Task {task} took {task_end - task_start} seconds")
self.tasks.task_done()
except Exception as ex: except Exception as ex:
print(ex) print(ex)
self.db.commit() self.db.commit()