Update.
Some checks failed
Build Base Application / Build (push) Has been cancelled
Details

Browse Source
This commit is contained in:
retoor 2025-06-01 00:11:07 +02:00
parent f2ff036455
commit 9bb53e266f
1 changed files with 8 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/app/app.py
View File

@ -1,10 +1,11 @@
import argparse import argparse
import asyncio
import base64 import base64
import json import json
import pathlib import pathlib
import time import time
import uuid import uuid
import asyncio
import aiohttp_jinja2 import aiohttp_jinja2
import dataset import dataset
import jinja2 import jinja2
@ -175,7 +176,9 @@ class WebDbApplication(BaseApplication):
): ):
self.db_web = db_web self.db_web = db_web
self.db_path = db_path self.db_path = db_path
self.db = db or dataset.connect(self.db_path) self.db = db or dataset.connect(
self.db_path, engine_kwargs={"connect_args": {"check_same_thread": False}}
)
super().__init__(*args, **kwargs) super().__init__(*args, **kwargs)
if not self.db_web: if not self.db_web:
@ -249,7 +252,7 @@ class WebDbApplication(BaseApplication):
return self.db["kv"].upsert({"key": key, "value": value}, ["key"]) return self.db["kv"].upsert({"key": key, "value": value}, ["key"])
async def get(self, key, default=None): async def get(self, key, default=None):
return await self.run_in_executor(self.sget,key, default) return await self.run_in_executor(self.sget, key, default)
def sget(self, key, default=None): def sget(self, key, default=None):
record = self.db["kv"].find_one(key=key) record = self.db["kv"].find_one(key=key)