apps/stealth-ai-relay
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(backend): add async lock to prevent Already borrowed issue

Browse Source
This commit is contained in:
h
2026-01-25 16:52:15 +01:00
parent a992e3f0c2
commit 1bffd71e7b
1 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
backend/src/utils/convex/client.py
View File

@@ -7,14 +7,18 @@ from convex import ConvexClient as SyncConvexClient
class ConvexClient: class ConvexClient:
def __init__(self, url: str) -> None: def __init__(self, url: str) -> None:
self._client = SyncConvexClient(url) self._client = SyncConvexClient(url)
self._lock = asyncio.Lock()
async def query(self, name: str, args: dict[str, Any] | None = None) -> Any: # noqa: ANN401 async def query(self, name: str, args: dict[str, Any] | None = None) -> Any: # noqa: ANN401
async with self._lock:
return await asyncio.to_thread(self._client.query, name, args or {}) return await asyncio.to_thread(self._client.query, name, args or {})
async def mutation(self, name: str, args: dict[str, Any] | None = None) -> Any: # noqa: ANN401 async def mutation(self, name: str, args: dict[str, Any] | None = None) -> Any: # noqa: ANN401
async with self._lock:
return await asyncio.to_thread(self._client.mutation, name, args or {}) return await asyncio.to_thread(self._client.mutation, name, args or {})
async def action(self, name: str, args: dict[str, Any] | None = None) -> Any: # noqa: ANN401 async def action(self, name: str, args: dict[str, Any] | None = None) -> Any: # noqa: ANN401
async with self._lock:
return await asyncio.to_thread(self._client.action, name, args or {}) return await asyncio.to_thread(self._client.action, name, args or {})
def subscribe(self, name: str, args: dict[str, Any] | None = None) -> Any: # noqa: ANN401 def subscribe(self, name: str, args: dict[str, Any] | None = None) -> Any: # noqa: ANN401